[[352802]]

 大綱

1. join方法使用
2. 進(jìn)程鎖
3. 進(jìn)程間通信

Process對(duì)象中的join方法

join方法表示等待子進(jìn)程結(jié)束后再繼續(xù)往下運(yùn)行，通常用于進(jìn)程間的同步，等待的總時(shí)間是子進(jìn)程中耗費(fèi)時(shí)間最長(zhǎng)的那個(gè)進(jìn)程運(yùn)行的時(shí)間。

join方法演示

對(duì)比一下兩種不同結(jié)果

進(jìn)程鎖

并發(fā)運(yùn)行時(shí)會(huì)出現(xiàn)同時(shí)操作一個(gè)文件時(shí)候，這時(shí)候會(huì)出現(xiàn)操作文件內(nèi)容混亂，需要加入鎖機(jī)制，由并發(fā)變成了串行。

import time 
import os 
from multiprocessing import Process, Lock 
 
def work(lock): 
    # 獲取鎖 
    lock.acquire() 
    print('{0} is 開(kāi)始工作'.format(os.getpid())) 
    time.sleep(2) 
    print('{0} is 結(jié)束工作'.format(os.getpid())) 
    # 釋放鎖 
    lock.release() 
 
lock = Lock() 
for i in range(3): 
    p = Process(target=work,args=(lock,)) 
    p.start() 

加入鎖機(jī)制變成串行時(shí)運(yùn)行結(jié)果

進(jìn)程間通信

在父進(jìn)程中創(chuàng)建兩個(gè)子進(jìn)程，一個(gè)往Queue里寫數(shù)據(jù)，一個(gè)從Queue里讀數(shù)據(jù)

Queue示例