from  multiprocessing import Process,Queue  #多進(jìn)程組件,隊(duì)列
import time,random  
#生產(chǎn)者方法
def producer(name,food,q):
    for i in  range(4):
        time.sleep(random.randint(1,3)) #模擬獲取數(shù)據(jù)時(shí)間
        f = '%s生產(chǎn)的%s%s'%(name,food,i)
        print(f)
        q.put(f) #添加進(jìn)隊(duì)列
#消費(fèi)者方法
def consumer(q,name):
    while True:
        food = q.get() #如果獲取不到，會(huì)一直阻塞進(jìn)程不會(huì)結(jié)束子進(jìn)程
        # 當(dāng)隊(duì)列中的數(shù)據(jù)是None的時(shí)候結(jié)束while循環(huán)
        if food is None:
            print('%s獲取到一個(gè)空'%name)
            break
        f = '\033[31m%s消費(fèi)了%s\033[0m' % (name, food)
        print(f)
        time.sleep(random.randint(1,3)) # 模擬消耗數(shù)據(jù)時(shí)間
if __name__ == '__main__':
    q = Queue()  # 創(chuàng)建隊(duì)列
    # 模擬生產(chǎn)者 生產(chǎn)數(shù)據(jù)
    p = Process(target=producer, args=('p', '包子', q)) #創(chuàng)建進(jìn)程
    p.start() #啟動(dòng)進(jìn)程
    p1 = Process(target=producer, args=('p1', '燒餅', q))
    p1.start()
   #模擬消費(fèi)者消費(fèi)數(shù)據(jù)
    c = Process(target=consumer, args=(q, 'c'))
    c.start()
    c1 = Process(target=consumer, args=(q, 'c1'))
    c1.start()
    p.join()#阻塞主進(jìn)程 直到p和p1 子進(jìn)程結(jié)束后才執(zhí)行q.put() 方法
    p1.join()#阻塞主進(jìn)程 直到p和p1 子進(jìn)程結(jié)束后才執(zhí)行q.put() 方法
    #為了確保生產(chǎn)者生產(chǎn)完所有數(shù)據(jù)后，
    #最后一個(gè)是None,方便結(jié)束子進(jìn)程中的while循環(huán),
    #否則會(huì)一直等待隊(duì)列中加入新數(shù)據(jù)。
    q.put(None)
    q.put(None)

from multiprocessing import JoinableQueue,Process
import time,random
#生產(chǎn)者方法
def producer(name,food,q):
    for i in range(4):
        time.sleep(random.randint(1, 2))
        f = '%s生產(chǎn)的%s%s'%(name,food,i)
        q.put(f)
        print(f)
    q.join()  #一直阻塞，等待消耗完所有的數(shù)據(jù)后才釋放
#消費(fèi)者方法
def consumer(name,q):
    while True:
        food = q.get()
        print('\033[31m%s消費(fèi)了%s\033[0m' % (name, food))
        time.sleep(random.randint(4,8))
        q.task_done() #每次消耗減1
if __name__ == '__main__':
    q = JoinableQueue()  #創(chuàng)建隊(duì)列
    #模擬生產(chǎn)者隊(duì)列
    p1 = Process(target=producer,args=('p1','包子',q))
    p1.start()
    p2 = Process(target=producer,args=('p2','燒餅',q))
    p2.start()
    #模擬消費(fèi)者隊(duì)列
    c1 = Process(target=consumer,args=('c1',q))
    c1.daemon = True #守護(hù)進(jìn)程：主進(jìn)程結(jié)束，子進(jìn)程也會(huì)結(jié)束
    c1.start()
    c2 = Process(target=consumer,args=('c2',q))
    c2.daemon = True
    c2.start()
    p1.join() #阻塞主進(jìn)程，等到p1子進(jìn)程結(jié)束才往下執(zhí)行
    p2.join()
    # q.task_done() 每次消耗隊(duì)列中的 任務(wù)數(shù)減1
    # q.join() 一直阻塞，等待隊(duì)列中的任務(wù)數(shù)消耗完才釋放
    # 因?yàn)橛?q.join 所有一直會(huì)等待 c1,c2 消耗完畢。才會(huì)執(zhí)行 p.join 后面的代碼
    # 因?yàn)?c1 c2 是守護(hù)進(jìn)程，所以到這一步主進(jìn)程代碼執(zhí)行完畢，主進(jìn)程會(huì)釋放死掉，
    # 所以 c1 c2 也會(huì)跟隨 主進(jìn)程釋放死掉。