python启动进程函数 python启动进程并获取pid( 二 )


上面这个程序的输出结果是:
我们来看一下上面这个程序到底做了什么 。首先我们创建了一个Queue对象:
然后,将这个空的Queue对象输入square_list函数 。该函数会将列表中的数平方,再使用 put() 方法放入队列中:
随后使用 get() 方法,将q打印出来,直至q重新称为一个空的Queue对象:
我们还是用一张图来帮助理解记忆:
一个Pipe对象只能有两个端点 。因此,当进程只需要双向通信时,它会比Queue对象更好用 。
multiprocessing模块提供了 Pipe() 函数 , 该函数返回由管道连接的一对连接对象 。Pipe() 返回的两个连接对象分别表示管道的两端 。每个连接对象都有 send() 和 recv() 方法 。
我们来看一个例子:
上面这个程序的输出结果是:
我们还是来看一下这个程序到底做了什么 。首先创建了一个Pipe对象:
与上文说的一样,该对象返回了一对管道两端的两个连接对象 。然后使用 send() 方法和 recv() 方法进行信息的传递 。就这么简单 。在上面的程序中,我们从一端向另一端发送一串消息 。在另一端,我们收到消息,并在收到END消息时退出 。
要注意的是,如果两个进程(或线程)同时尝试从管道的同一端读取或写入管道中的数据,则管道中的数据可能会损坏 。不过不同的进程同时使用管道的两端是没有问题的 。还要注意,Queue对象在进程之间进行了适当的同步,但代价是增加了计算复杂度 。因此,Queue对象对于线程和进程是相对安全的 。
最后我们还是用一张图来示意:
Python的multiprocessing模块还剩最后一篇文章:多进程的同步与池化
敬请期待啦!
python中的进程-实战部分 如果想python启动进程函数了解进程 可以先看一下这一篇 python中的进程-理论部分
python中的多线程无法利用多核优势python启动进程函数,如果想要充分地使用多核CPU的资源(os.cpu_count()查看),在python中大部分情况需要使用多进程 。Python提供了multiprocessing 。
multiprocessing模块用来开启子进程,并在子进程中执行python启动进程函数我们定制的任务(比如函数),该模块与多线程模块threading的编程接口类似 。
multiprocessing模块的功能众多:支持子进程、通信和共享数据、执行不同形式的同步 , 提供了Process、Queue、Pipe、Lock等组件 。
需要再次强调的一点是:与线程不同,进程没有任何共享状态,进程修改的数据 , 改动仅限于该进程内 。
创建进程的类:
参数介绍:
group参数未使用,值始终为None
target表示调用对象 , 即子进程要执行的任务
args表示调用对象的位置参数元组,args=(1,2,'tiga',)
kwargs表示调用对象的字典,kwargs={'name':'tiga','age':18}
name为子进程的名称
方法介绍:
p.start():启动进程,并调用该子进程中的p.run()
p.run():进程启动时运行的方法 , 正是它去调用target指定的函数,我们自定义类的类中一定要实现该方法
p.terminate():强制终止进程p,不会进行任何清理操作 , 如果p创建了子进程,该子进程就成了僵尸进程,使用该方法需要特别小心这种情况 。如果p还保存了一个锁那么也将不会被释放,进而导致死锁
p.is_alive():如果p仍然运行,返回True
p.join([timeout]):主线程等待p终止(强调:是主线程处于等的状态,而p是处于运行的状态) 。timeout是可选的超时时间,需要强调的是 , p.join只能join住start开启的进程,而不能join住run开启的进程
属性介绍:
注意:在windows中Process()必须放到# if __name__ == '__main__':下

推荐阅读