#生產(chǎn)者消費(fèi)者模型 其實(shí)服務(wù)器集群就是這個(gè)模型
# 這里介紹的是非yield方法實(shí)現(xiàn)過(guò)程

import threading,time
import queue
q = queue.Queue(maxsize=10)

def Producer(anme):
 # for i in range(10):
 #  q.put('骨頭%s'%i)
 count = 1
 while True:
  q.put('骨頭%s'%count)
  print('生產(chǎn)了骨頭',count)
  count += 1
  time.sleep(1)

def Consumer(name):
 # while q.qsize() >0:
 while True:
  print('[%s] 取到[%s] 并且吃了它...'%(name,q.get()))
  time.sleep(1)

p = threading.Thread(target=Producer,args=('shenchanzhe',))
c = threading.Thread(target=Consumer,args=('xiaofeizhe01',))
c1 = threading.Thread(target=Consumer,args=('xiaofeizhe02',))

p.start()
c.start()
c1.start()

#生產(chǎn)者和消費(fèi)者，使用生成器的方式，就是一個(gè)簡(jiǎn)單的并行，
import time
# 這是一個(gè)消費(fèi)者 一直在等待完成吃包子的動(dòng)作
def consumer(name):
 print('%s準(zhǔn)備吃包子了！'%name) #打印出對(duì)應(yīng)的消費(fèi)者的名字
 while True: #執(zhí)行一個(gè)死循環(huán) 實(shí)際上就是需要調(diào)用時(shí)才會(huì)執(zhí)行，沒(méi)有調(diào)用就會(huì)停止在yield
  baozi = yield #在它就收到內(nèi)容的時(shí)候后就把內(nèi)容傳給baozi
  print('包子【%s】來(lái)了，被【%s】吃了'%(baozi,name))
def producer(name):
 c1 = consumer('A') #它只是把c1變成一個(gè)生成器
 c2 = consumer('B')
 c1.__next__() #第一個(gè)next只是會(huì)走到y(tǒng)ield然后停止
 c2.__next__()
 print('老子開(kāi)始做包子了')
 for i in range(1,10):
  time.sleep(1)
  print('三秒做了兩個(gè)包子')
  c1.send(i) #這一步其實(shí)就是調(diào)用next方法的同時(shí)傳一個(gè)參數(shù)i給field接收，然后baozi=i
  c2.send(i+1)
  #其實(shí)這里是這樣的，在send的時(shí)候只是繼續(xù)執(zhí)行yield下面的語(yǔ)句，然后去去yield，再次停在這兒

# producer('aea')
c = consumer('aaa') #沒(méi)next一次就會(huì)將程序執(zhí)行一次
c.__next__()
c.__next__()
c.__next__()