Python中多进程—Join方法使用、进程锁及进程间通信,


 大纲

Process对象中的join方法

join方法表示等待子进程结束后再继续往下运行,通常用于进程间的同步,等待的总时间是子进程中耗费时间最长的那个进程运行的时间。

join方法演示


对比一下两种不同结果

进程锁

并发运行时会出现同时操作一个文件时候,这时候会出现操作文件内容混乱,需要加入锁机制,由并发变成了串行。

  1. import time 
  2. import os 
  3. from multiprocessing import Process, Lock 
  4.  
  5. def work(lock): 
  6.     # 获取锁 
  7.     lock.acquire() 
  8.     print('{0} is 开始工作'.format(os.getpid())) 
  9.     time.sleep(2) 
  10.     print('{0} is 结束工作'.format(os.getpid())) 
  11.     # 释放锁 
  12.     lock.release() 
  13.  
  14. lock = Lock() 
  15. for i in range(3): 
  16.     p = Process(target=work,args=(lock,)) 
  17.     p.start() 

 

加入锁机制变成串行时运行结果

进程间通信

在父进程中创建两个子进程,一个往Queue里写数据,一个从Queue里读数据


Queue示例

评论关闭