生產者消費者模型中Queue理解

2021-08-10 04:01:48 字數 878 閱讀 8812

在生產者消費者模型中,queue用作兩者之間的緩衝

但是由於queue的內在機理中包含著自動執行wait、notify等功能的機制,於是單從程式**上看起來會很奇怪。

比如這段****自星火部落格)

from multiprocessing import process,queue

import time,random,os

defconsumer

(q):

while

true:

time.sleep(random.randint(1,3))

res=q.get()

if res is

none:break

print('\033[45m消費者拿到了:%s\033[0m' %res)

defproducer

(seq,q):

for item in seq:

time.sleep(random.randint(1,3))

print('\033[46m生產者生產了:%s\033[0m' %item)

q.put(item)

if __name__ == '__main__':

q=queue()

c=process(target=consumer,args=(q,))

c.start()

producer(('包子%s' %i for i in range(5)),q)

q.put(none)

c.join()

print('主線程')

生產者消費者模型

1.生產者消費者問題 producer consumer 有限緩衝,多執行緒同步。生產者執行緒和消費者執行緒共享固定大小緩衝區。2.關鍵是保證生產者不會再緩衝區滿時加入資料,消費者不會在緩衝區空時消耗資料。3.解決辦法 讓生產者在緩衝區滿時休眠,等下次消費者消耗緩衝區中的資料的時候,生產者才能被喚醒...

生產者消費者模型

生產者與消費者 3,2,1 三種關係 生產者與消費者 互斥,同步 消費者與消費者 互斥 生產者與生產者 互斥 條件變數 int pthread cond destroy pthread cond t cond int pthread cond init pthread cond t restrict...

生產者消費者模型

當佇列滿時,生產者需要等待佇列有空間才能繼續往裡面放入商品,而在等待的期間內,生產者必須釋放對臨界資源 即佇列 的占用權。因為生產者如果不釋放對臨界資源的占用權,那麼消費者就無法消費佇列中的商品,就不會讓佇列有空間,那麼生產者就會一直無限等待下去。因此,一般情況下,當佇列滿時,會讓生產者交出對臨界資...