美文网首页
python 学习笔记 (进程multiprocessing)2

python 学习笔记 (进程multiprocessing)2

作者: 我是帅气的石头 | 来源:发表于2018-05-20 21:55 被阅读0次

    进程的概念

    进程的概念:正在进行的一个过程或者说一个任务,而负责执行任务的则是CPU,进程本身是
    一个抽象的概念,即进程就是一个过程、一个任务。
    CPU描述的是一个程序的执行过程.
    进程之间是如何做到并发的:CPU在各个任务之间来回的进行切换,并在切换的过程当中保存当前
    进程的执行状态(保存蛋糕的执行过程)。
    进程与程序的区别:程序相当于菜谱,而进程相当于做菜的整个过程。
    需要强调的是:同一个程序执行两次(双击),那也是两个进程,比如打开暴风影音,虽然都是同一个软件,但是一个可以播放a,一个可以播放b.

    并行和并发的概念

    无论是并行还是并发,在用户看来都是同时运行的,不管是进程还是线程,都只是一个任务而已,
    真正干活的是CPU,CPU来做这些任务,而一个cpu(单核)同一时刻只能执行一个任务。
    并行:多个任务同时运行,只有具备多个cpu才能实现并行,含有几个cpu,也就意味着在同一时刻可以执行几个任务。
    并发:是伪并行,即看起来是同时运行的,实际上是单个CPU在多道程序之间来回的进行切换。

    同步和异步

    同步就是指一个进程在执行某个请求的时候,若该请求需要一段时间才能返回信息,那么这个进程将会一直等待下去,直到收到返回信息才继续执行下去。
    异步是指进程不需要一直等下去,而是继续执行下面的操作,不管其他进程的状态。当有消息返回时系统会通知进行处理,这样可以提高执行的效率。
    打电话的过程就是同步通信,发短信时就是异步通信。

    multiprocessing模块

    multiprocessing模块提供了一个Process类来代表一个进程对象,下面的例子演示了启动一个子进程并等待其结束:

    from multiprocessing import Process
    import os
    
    # 子进程要执行的代码
    def run_proc(name):
        print 'Run child process %s (%s)...' % (name, os.getpid())
    
    if __name__=='__main__':
        print 'Parent process %s.' % os.getpid()
        p = Process(target=run_proc, args=('test',))
        print 'Process will start.'
        p.start()
        p.join()
        print 'Process end.'
    

    执行结果:

    Parent process 928.
    Process will start.
    Run child process test (929)...
    Process end.
    

    创建子进程时,只需要传入一个执行函数和函数的参数,创建一个Process实例,用start()方法启动,这样创建进程比fork()还要简单。

    join()方法可以等待子进程结束后再继续往下运行,通常用于进程间的同步

    def worker(args, interval):
        print("start worker {0}".format(args))
        time.sleep(interval)
        print("end worker {0}".format(args))
    
    def main():
        print("start main")
        p1 = multiprocessing.Process(target=worker, args=(1, 1))
        p2 = multiprocessing.Process(target=worker, args=(2, 2))
        p3 = multiprocessing.Process(target=worker, args=(3, 3))
        p1.start()
        p2.start()
        p3.start()
        print("end main")
    
    if __name__ == '__main__':
        main()
    
    # p = multiprocessing.Process(target=, args=)
    # target   指定的是当进程执行时,需要执行的函数
    # args     是当进程执行时,需要给函数传入的参数
    # 注意: args必须是一个tuple, 特别是当函数需要传入一个参数时 (1,)
    # p 代表的是一个多进程,
    # p.is_alive()     判断进程是否存活
    # p.run()          启动进程
    # p.start()        启动进程,他会自动调用run方法,推荐使用start
    # p.join(timeout)  等待子进程结束或者到超时时间
    # p.terminate()    强制子进程退出
    # p.name           进程的名字
    # p.pid            进程的pid
    
    

    相关文章

      网友评论

          本文标题:python 学习笔记 (进程multiprocessing)2

          本文链接:https://www.haomeiwen.com/subject/fcqxjftx.html