#生產者消費者模型 其實服務器集群就是這個模型# 這里介紹的是非yield方法實現過程import threading,timeimport queueq = 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('生產了骨頭',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()

#生產者和消費者，使用生成器的方式，就是一個簡單的并行，import time# 這是一個消費者 一直在等待完成吃包子的動作def consumer(name): print('%s準備吃包子了！'%name) #打印出對應的消費者的名字 while True: #執行一個死循環 實際上就是需要調用時才會執行，沒有調用就會停止在yield  baozi = yield #在它就收到內容的時候后就把內容傳給baozi  print('包子【%s】來了，被【%s】吃了'%(baozi,name))def producer(name): c1 = consumer('A') #它只是把c1變成一個生成器 c2 = consumer('B') c1.__next__() #第一個next只是會走到yield然后停止 c2.__next__() print('老子開始做包子了') for i in range(1,10):  time.sleep(1)  print('三秒做了兩個包子')  c1.send(i) #這一步其實就是調用next方法的同時傳一個參數i給field接收，然后baozi=i  c2.send(i+1)  #其實這里是這樣的，在send的時候只是繼續執行yield下面的語句，然后去去yield，再次停在這兒# producer('aea')c = consumer('aaa') #沒next一次就會將程序執行一次c.__next__()c.__next__()c.__next__()