程式碼演示

'''
    首先，消費者函式從佇列中取一次數值然後呼叫q.task_done()通知生產者函式，<font color="#ff0000">該元素</font>我已經取過了，直到將全部元素取出。
    在生產者函式中呼叫q.join()時，函式被掛起，直到佇列的資料被全部取走，函式才能繼續執行，生產者函式執行結束後，消費者函式還在等待佇列中的資料，但此時消費者函式已經沒有存活的必要，所以當主程序結束時，可以將該執行消費者函式的子程序帶走，設定為守護程序即可'''
import os
import time
from multiprocessing import
 
 Process, JoinableQueue


def producer0(q):
    for i in range(5):
        print('%s 生產了 %s' % (os.getpid(), i))
        q.put(i)
    q.join()


def producer1(q):
    for i in range(5):
        print('%s 生產了 %s' % (os.getpid(), i))
        q.put(i)
    q.join()


def producer2(q):
    for i in range(5
 
):
        print('%s 生產了 %s' % (os.getpid(), i))
        q.put(i)
    q.join()


def consumer(q):
    while 1:
        res = q.get()
        time.sleep(3)
        print('%s 消費了 %s' % (os.getpid(), res))
        q.task_done()


if __name__ == '__main__':

    q = JoinableQueue()

    p1 = Process(target=producer0, args=(q,))
    p2 = Process(target=producer1, args=(q,))
    p3 = Process(target=producer2, args=(q,))

    p4 = Process(target=consumer, args=(q,))
    p5 = Process(target=consumer, args=(q,))

    p_l = [p1, p2, p3, p4, p5]
    #資料取完後消費者還在等著資料加入佇列，但是生產者函式已經結束了，所以消費者可以隨著主程序的結束而結束，所以將消費者函式設定為守護程序。
 

    p4.daemon = True
    p5.daemon = True

    for p in p_l:
        p.start()

    p1.join()
    p2.join()
    p3.join()

    print('主程序')