快捷導(dǎo)航

詳解Python 模擬實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模式的實(shí)例

更新時(shí)間：2017年08月10日 09:52:26 作者：qindongliang1922

這篇文章主要介紹了詳解Python 模擬實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模式的實(shí)例的相關(guān)資料,這里使用了線程知識(shí)，隊(duì)列知識(shí)及循環(huán)的知識(shí)，需要的朋友可以參考下

散仙使用python3.4模擬實(shí)現(xiàn)的一個(gè)生產(chǎn)者與消費(fèi)者的例子，用到的知識(shí)有線程，隊(duì)列，循環(huán)等，源碼如下：

Python代碼

import queue 
import time 
import threading 
import random 
 
 
q=queue.Queue(5) 
 
#生產(chǎn)者 
def pr(): 
  name=threading.current_thread().getName() 
  print(name+"線程啟動(dòng)......") 
  for i in range(100): 
    t=random.randint(2,9) 
    print(name,"睡眠時(shí)間: ",t) 
    time.sleep(t); 
    d="A"+str(i) 
    print(name+"正在存第",i+1,"個(gè)數(shù)據(jù): ",d) 
    #q.put("A"+str(i),False,2000) 
    q.put(d) 
  print("生產(chǎn)完畢!") 
 
 
#消費(fèi)者 
def co(): 
  name=threading.current_thread().getName() 
  time.sleep(1) 
  print(name+"線程啟動(dòng)......") 
 
  while True: 
    print(name+"檢測(cè)到隊(duì)列數(shù)量: ",q.qsize()) 
    t=random.randint(2,9) 
    print(name,"睡眠時(shí)間: ",t) 
    data=q.get(); 
    print(name+"消費(fèi)一個(gè)數(shù)據(jù): ",data) 
 
 
 
 
p=threading.Thread(target=pr,name="生產(chǎn)者") 
c=threading.Thread(target=co,name="消費(fèi)者1") 
c2=threading.Thread(target=co,name="消費(fèi)者2") 
 
p.start() 
c.start() 
c2.start()

在本例里面散仙啟動(dòng)了1個(gè)生產(chǎn)者線程，2個(gè)消費(fèi)者線程，打印效果如下：

Python代碼

生產(chǎn)者線程啟動(dòng)...... 
生產(chǎn)者 睡眠時(shí)間: 4 
消費(fèi)者1線程啟動(dòng)...... 
消費(fèi)者1檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者1 睡眠時(shí)間: 2 
消費(fèi)者2線程啟動(dòng)...... 
消費(fèi)者2檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者2 睡眠時(shí)間: 3 
生產(chǎn)者正在存第 1 個(gè)數(shù)據(jù): A0 
生產(chǎn)者 睡眠時(shí)間: 9 
消費(fèi)者1消費(fèi)一個(gè)數(shù)據(jù): A0 
消費(fèi)者1檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者1 睡眠時(shí)間: 8 
生產(chǎn)者正在存第 2 個(gè)數(shù)據(jù): A1 
生產(chǎn)者 睡眠時(shí)間: 5 
消費(fèi)者2消費(fèi)一個(gè)數(shù)據(jù): A1 
消費(fèi)者2檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者2 睡眠時(shí)間: 7 
生產(chǎn)者正在存第 3 個(gè)數(shù)據(jù): A2 
生產(chǎn)者 睡眠時(shí)間: 8 
消費(fèi)者1消費(fèi)一個(gè)數(shù)據(jù): A2 
消費(fèi)者1檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者1 睡眠時(shí)間: 2 
生產(chǎn)者正在存第 4 個(gè)數(shù)據(jù): A3 
生產(chǎn)者 睡眠時(shí)間: 7 
消費(fèi)者2消費(fèi)一個(gè)數(shù)據(jù): A3 
消費(fèi)者2檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者2 睡眠時(shí)間: 9 
生產(chǎn)者正在存第 5 個(gè)數(shù)據(jù): A4 
生產(chǎn)者 睡眠時(shí)間: 2 
消費(fèi)者1消費(fèi)一個(gè)數(shù)據(jù): A4 
消費(fèi)者1檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者1 睡眠時(shí)間: 5 
生產(chǎn)者正在存第 6 個(gè)數(shù)據(jù): A5 
生產(chǎn)者 睡眠時(shí)間: 5 
消費(fèi)者2消費(fèi)一個(gè)數(shù)據(jù): A5 
消費(fèi)者2檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者2 睡眠時(shí)間: 6 
生產(chǎn)者正在存第 7 個(gè)數(shù)據(jù): A6 
生產(chǎn)者 睡眠時(shí)間: 7 
消費(fèi)者1消費(fèi)一個(gè)數(shù)據(jù): A6 
消費(fèi)者1檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者1 睡眠時(shí)間: 7 
生產(chǎn)者正在存第 8 個(gè)數(shù)據(jù): A7 
生產(chǎn)者 睡眠時(shí)間: 3 
消費(fèi)者2消費(fèi)一個(gè)數(shù)據(jù): A7 
消費(fèi)者2檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者2 睡眠時(shí)間: 8 
生產(chǎn)者正在存第 9 個(gè)數(shù)據(jù): A8 
生產(chǎn)者 睡眠時(shí)間: 2 
消費(fèi)者1消費(fèi)一個(gè)數(shù)據(jù): A8 
消費(fèi)者1檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者1 睡眠時(shí)間: 4 
生產(chǎn)者正在存第 10 個(gè)數(shù)據(jù): A9 
生產(chǎn)者 睡眠時(shí)間: 4 
消費(fèi)者2消費(fèi)一個(gè)數(shù)據(jù): A9 
消費(fèi)者2檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者2 睡眠時(shí)間: 5 
生產(chǎn)者正在存第 11 個(gè)數(shù)據(jù): A10 
生產(chǎn)者 睡眠時(shí)間: 2 
消費(fèi)者1消費(fèi)一個(gè)數(shù)據(jù): A10 
消費(fèi)者1檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者1 睡眠時(shí)間: 3 
生產(chǎn)者正在存第 12 個(gè)數(shù)據(jù): A11 
生產(chǎn)者 睡眠時(shí)間: 3 
消費(fèi)者2消費(fèi)一個(gè)數(shù)據(jù): A11 
消費(fèi)者2檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者2 睡眠時(shí)間: 3 
生產(chǎn)者正在存第 13 個(gè)數(shù)據(jù): A12 
生產(chǎn)者 睡眠時(shí)間: 3 
消費(fèi)者1消費(fèi)一個(gè)數(shù)據(jù): A12 
消費(fèi)者1檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者1 睡眠時(shí)間: 3 
生產(chǎn)者正在存第 14 個(gè)數(shù)據(jù): A13 
生產(chǎn)者 睡眠時(shí)間: 8 
消費(fèi)者2消費(fèi)一個(gè)數(shù)據(jù): A13 
消費(fèi)者2檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者2 睡眠時(shí)間: 7 
生產(chǎn)者正在存第 15 個(gè)數(shù)據(jù): A14 
生產(chǎn)者 睡眠時(shí)間: 3 
消費(fèi)者1消費(fèi)一個(gè)數(shù)據(jù): A14 
消費(fèi)者1檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者1 睡眠時(shí)間: 7 
生產(chǎn)者正在存第 16 個(gè)數(shù)據(jù): A15 
生產(chǎn)者 睡眠時(shí)間: 2 
消費(fèi)者2消費(fèi)一個(gè)數(shù)據(jù): A15 
消費(fèi)者2檢測(cè)到隊(duì)列數(shù)量: 0 
消費(fèi)者2 睡眠時(shí)間: 9

從這個(gè)例子中，我們發(fā)現(xiàn)利用隊(duì)列，來做同步時(shí)非常簡(jiǎn)單方便的，除此之外隊(duì)列，還有如下幾個(gè)方便的方法：

介紹一下此包中的常用方法:

Queue.qsize() 返回隊(duì)列的大小  
Queue.empty() 如果隊(duì)列為空，返回True,反之False  
Queue.full() 如果隊(duì)列滿了，返回True,反之False 
Queue.full 與 maxsize 大小對(duì)應(yīng)  
Queue.get([block[, timeout]])獲取隊(duì)列，timeout等待時(shí)間  
Queue.get_nowait() 相當(dāng)Queue.get(False) 
非阻塞 Queue.put(item) 寫入隊(duì)列，timeout等待時(shí)間  
Queue.put_nowait(item) 相當(dāng)Queue.put(item, False) 
Queue.task_done() 在完成一項(xiàng)工作之后，Queue.task_done()函數(shù)向任務(wù)已經(jīng)完成的隊(duì)列發(fā)送一個(gè)信號(hào) 
Queue.join() 實(shí)際上意味著等到隊(duì)列為空，再執(zhí)行別的操作

以上就是詳解Python 模擬實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模式的實(shí)例，如有疑問請(qǐng)留言或者到本站社區(qū)交流討論，感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！

您可能感興趣的文章: