from multiprocessing import Process, Queue
import time
 
# 消費(fèi)者方法
def consumer(q, name):
  while True:
    res = q.get()
    # if res is None: break
    print("%s 吃了 %s" % (name, res))
 
# 生產(chǎn)者方法
def producer(q, name, food):
  for i in range(3):
    time.sleep(1) # 模擬生產(chǎn)西瓜的時(shí)間延遲
    res = "%s %s" % (food, i)
    print("%s 生產(chǎn)了 %s" % (name, res))
    # 把生產(chǎn)的vegetable放入到隊(duì)列中
    q.put(res)
 
if __name__ == "__main__":
  #創(chuàng)建隊(duì)列
  q = Queue()
  # 創(chuàng)建生產(chǎn)者
  p1 = Process(target=producer, args=(q, "kelly", "西瓜"))
  c1 = Process(target=consumer, args=(q, "peter",))
  p1.start()
  c1.start()
 
  # p1.join()
  # q.put(None)
  print("主進(jìn)程")

def consumer():
  if res is None: break
 
if __name__ == "__main__":
p1.join() 
q.put(None)

from multiprocessing import Process, Queue
import time
 
 
# 消費(fèi)者方法
def consumer(q, name):
  while True:
    res = q.get()
    if res is None: break
    print("%s 吃了 %s" % (name, res))
 
 
# 生產(chǎn)者方法
def producer(q, name, food):
  for i in range(3):
    time.sleep(1) # 模擬生產(chǎn)西瓜的時(shí)間延遲
    res = "%s %s" % (food, i)
    print("%s 生產(chǎn)了 %s" % (name, res))
    # 把生產(chǎn)的vegetable放入到隊(duì)列中
    q.put(res)
 
 
if __name__ == "__main__":
  # 創(chuàng)建隊(duì)列
  q = Queue()
  # 創(chuàng)建生產(chǎn)者
  p1 = Process(target=producer, args=(q, "kelly", "西瓜"))
  p2 = Process(target=producer, args=(q, "kelly2", "香蕉"))
  c1 = Process(target=consumer, args=(q, "peter",))
  c2 = Process(target=consumer, args=(q, "peter2",))
  c3 = Process(target=consumer, args=(q, "peter3",))
  p1.start()
  p2.start()
  c1.start()
  c2.start()
  c3.start()
 
  p1.join()
  p2.join()
  q.put(None)
  q.put(None)
  q.put(None)
  print("主進(jìn)程")

from multiprocessing import Process,JoinableQueue
import time
 
 
# 消費(fèi)者方法
def consumer(q, name):
  while True:
    res = q.get()
    if res is None: break
    print("%s 吃了 %s" % (name, res))
    q.task_done() # 發(fā)送信號(hào)給q.join(),表示已經(jīng)從隊(duì)列中取走一個(gè)值并處理完畢了
 
 
# 生產(chǎn)者方法
def producer(q, name, food):
  for i in range(3):
    time.sleep(1) # 模擬生產(chǎn)西瓜的時(shí)間延遲
    res = "%s %s" % (food, i)
    print("%s 生產(chǎn)了 %s" % (name, res))
    # 把生產(chǎn)的vegetable放入到隊(duì)列中
    q.put(res)
  q.join() # 等消費(fèi)者把自己放入隊(duì)列的所有元素取完之后才結(jié)束
 
 
if __name__ == "__main__":
  # q = Queue()
  q = JoinableQueue()
  # 創(chuàng)建生產(chǎn)者
  p1 = Process(target=producer, args=(q, "kelly", "西瓜"))
  p2 = Process(target=producer, args=(q, "kelly2", "藍(lán)莓"))
  # 創(chuàng)建消費(fèi)者
  c1 = Process(target=consumer, args=(q, "peter",))
  c2 = Process(target=consumer, args=(q, "peter2",))
  c3 = Process(target=consumer, args=(q, "peter3",))
 
  c1.daemon = True
  c2.daemon = True
  c3.daemon = True
 
  p_l = [p1, p2, c1, c2, c3]
  for p in p_l:
    p.start()
  
  p1.join()
  p2.join()
  # 1.主進(jìn)程等待p1,p2進(jìn)程結(jié)束才繼續(xù)執(zhí)行
  # 2.由于q.join()的存在,生產(chǎn)者只有等隊(duì)列中的元素被消費(fèi)完才會(huì)結(jié)束
  # 3.生產(chǎn)者結(jié)束了,就代表消費(fèi)者已經(jīng)消費(fèi)完了,也可以結(jié)束了,所以可以把消費(fèi)者設(shè)置為守護(hù)進(jìn)程(隨著主進(jìn)程的退出而退出)
 
  print("主進(jìn)程")