#管道實現生產者消費者模型
## 應該特別注意管道端點的正確管理問題，如果是生產者或消費者中都沒有使用管道的端點就應該將它關閉
#這也說明了為何在生產者中關閉了管道的輸出端，在消費者中關閉管道的輸入端。如果忘記執行這個步驟
#程式可能在消費者中的recv()操作上掛起。管道是由作業系統進行引用計數的，必須在所有程序中關閉管道
#後才能生成eoferoor異常，因此，在生產者中關閉管道不會有任何效果，除非消費者也關閉了相同的管道端點。
#pipe 存在資料不安全性
#存在管道的一端被多個消費者程序取同乙個資料的問題，出現時會報錯。佇列是同一時間只能有乙個程序取資料。
#解決方案，加上鎖,，管道的操作加上鎖後，其實就是佇列了，管道比佇列底層，管道走的是socket。佇列是資料安全性的
#佇列相當於帶鎖的管道
import
time
import
random
from multiprocessing import
process, pipe, lock
defconsumer(con, pro, name, lock):
'''# 消費者一方
:param con:
:param pro:
:param name:
:return:
'''pro.close()
#消費者不需要生產者一方的管道端點，關閉掉
while
true:
try:
lock.acquire()
#管道操作前鎖，防止多個程序爭搶乙個資料
food = con.recv() #
消費者用消費者的管道端點，從管道中獲取資料，當管道的所有端點被關閉掉時（我認為是管道的一端被全部關閉時），會丟擲異常錯誤eoferror
lock.release()
print('
%s 吃了 %s
' %(name, food))
time.sleep(random.randint(1, 3))
except
eoferror:
print('
管道丟擲了異常eoferror，管道所有端點被關閉掉，說明生產者生產完了')
con.close()
lock.release()
break
defproducer(con, pro, name, food):
'''生產者一方
:param con: # 消費者一方的管道端點
:param pro: # 生產者一方的管道端點
:param name: # 誰生產
:param food: # 生產的東西
:return:
'''con.close()
#生產者不需要消費者一方的管道端點，關閉掉
for i in range(4):
time.sleep(random.randint(1, 3))
f = '
%s 生產了 第%s個%s
' %(name, i, food)
(f) pro.send(f)
#生產者操作生產管道端點向管道中傳輸資料
pro.close() #
生產者生產完了後，將生產者管道端點關閉掉
if__name__ == '
__main__':
con, pro = pipe() #
建立乙個管道，一端給消費者用，一端給生產者用
lock =lock()
p = process(target=producer, args=(con, pro, '
why', '泔水'
)) p.start()
p2 = process(target=consumer, args=(con, pro, '
fqq'
, lock))
p2.start()
p3 = process(target=consumer, args=(con, pro, '
fqq2
', lock))
p3.start()
con.close()
pro.close()
生產者消費者模型
1.生產者消費者問題 producer consumer 有限緩衝，多執行緒同步。生產者執行緒和消費者執行緒共享固定大小緩衝區。2.關鍵是保證生產者不會再緩衝區滿時加入資料，消費者不會在緩衝區空時消耗資料。3.解決辦法 讓生產者在緩衝區滿時休眠，等下次消費者消耗緩衝區中的資料的時候，生產者才能被喚醒...
生產者消費者模型
生產者與消費者 3,2,1 三種關係 生產者與消費者 互斥，同步 消費者與消費者 互斥 生產者與生產者 互斥 條件變數 int pthread cond destroy pthread cond t cond int pthread cond init pthread cond t restrict...
生產者消費者模型
當佇列滿時，生產者需要等待佇列有空間才能繼續往裡面放入商品，而在等待的期間內，生產者必須釋放對臨界資源 即佇列 的占用權。因為生產者如果不釋放對臨界資源的占用權，那麼消費者就無法消費佇列中的商品，就不會讓佇列有空間，那麼生產者就會一直無限等待下去。因此，一般情況下，當佇列滿時，會讓生產者交出對臨界資...