生產者 消費者模型

2021-09-01 20:59:41 字數 1160 閱讀 7839

程式1

# 定義生產者函式

def producer():

arr =

for i in range(100):

return arr

# 定義消費者函式

def customer(arr):

for i, v in enumerate(arr):

print('第%d位顧客,%s' %(i, v))

arr = producer()

customer(arr)

程式二
def producer():

for i in range(100):

yield '第%d籠包子' % i

def customer():

g = producer()

while 1:

try:

print(g.__next__())

except:

print('賣完啦!')

break

customer()

send
def test():

print('開始啦!')

res = yield 'round one'

print('%s獲勝' % res)

print('第二回合')

res = yield 'round two'

print('%s獲勝' % res)

print('win!')

g = test()

# 開始啦!

g.__next__()

g.send('小豬佩奇')

# 小豬佩奇獲勝

# 第二回合

併發
import time

def customer():

while 1:

food = yield

time.sleep(0.2)

print(food)

def producer():

c1 = customer()

c1.__next__()

for i in range(100):

time.sleep(0.2)

c1.send(i)

producer()

生產者消費者模型

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

生產者消費者模型

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

生產者消費者模型

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