詳解Python 模擬實現(xiàn)生產(chǎn)者消費者模式的實例
散仙使用python3.4模擬實現(xiàn)的一個生產(chǎn)者與消費者的例子，用到的知識有線程，隊列，循環(huán)等，源碼如下：
Python代碼
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
import queue import time import threading import random q=queue.Queue(5) #生產(chǎn)者 def pr(): name=threading.current_thread().getName() print(name+"線程啟動......") for i in range(100): t=random.randint(2,9) print(name,"睡眠時間: ",t) time.sleep(t); d="A"+str(i) print(name+"正在存第",i+1,"個數(shù)據(jù): ",d) #q.put("A"+str(i),False,2000) q.put(d) print("生產(chǎn)完畢!") #消費者 def co(): name=threading.current_thread().getName() time.sleep(1) print(name+"線程啟動......") while True: print(name+"檢測到隊列數(shù)量: ",q.qsize()) t=random.randint(2,9) print(name,"睡眠時間: ",t) data=q.get(); print(name+"消費一個數(shù)據(jù): ",data) p=threading.Thread(target=pr,name="生產(chǎn)者") c=threading.Thread(target=co,name="消費者1") c2=threading.Thread(target=co,name="消費者2") p.start() c.start() c2.start() |
在本例里面散仙啟動了1個生產(chǎn)者線程，2個消費者線程，打印效果如下：
Python代碼
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
生產(chǎn)者線程啟動...... 生產(chǎn)者 睡眠時間: 4消費者1線程啟動...... 消費者1檢測到隊列數(shù)量: 0消費者1 睡眠時間: 2消費者2線程啟動...... 消費者2檢測到隊列數(shù)量: 0消費者2 睡眠時間: 3生產(chǎn)者正在存第 1 個數(shù)據(jù): A0 生產(chǎn)者 睡眠時間: 9消費者1消費一個數(shù)據(jù): A0 消費者1檢測到隊列數(shù)量: 0消費者1 睡眠時間: 8生產(chǎn)者正在存第 2 個數(shù)據(jù): A1 生產(chǎn)者 睡眠時間: 5消費者2消費一個數(shù)據(jù): A1 消費者2檢測到隊列數(shù)量: 0消費者2 睡眠時間: 7生產(chǎn)者正在存第 3 個數(shù)據(jù): A2 生產(chǎn)者 睡眠時間: 8消費者1消費一個數(shù)據(jù): A2 消費者1檢測到隊列數(shù)量: 0消費者1 睡眠時間: 2生產(chǎn)者正在存第 4 個數(shù)據(jù): A3 生產(chǎn)者 睡眠時間: 7消費者2消費一個數(shù)據(jù): A3 消費者2檢測到隊列數(shù)量: 0消費者2 睡眠時間: 9生產(chǎn)者正在存第 5 個數(shù)據(jù): A4 生產(chǎn)者 睡眠時間: 2消費者1消費一個數(shù)據(jù): A4 消費者1檢測到隊列數(shù)量: 0消費者1 睡眠時間: 5生產(chǎn)者正在存第 6 個數(shù)據(jù): A5 生產(chǎn)者 睡眠時間: 5消費者2消費一個數(shù)據(jù): A5 消費者2檢測到隊列數(shù)量: 0消費者2 睡眠時間: 6生產(chǎn)者正在存第 7 個數(shù)據(jù): A6 生產(chǎn)者 睡眠時間: 7消費者1消費一個數(shù)據(jù): A6 消費者1檢測到隊列數(shù)量: 0消費者1 睡眠時間: 7生產(chǎn)者正在存第 8 個數(shù)據(jù): A7 生產(chǎn)者 睡眠時間: 3消費者2消費一個數(shù)據(jù): A7 消費者2檢測到隊列數(shù)量: 0消費者2 睡眠時間: 8生產(chǎn)者正在存第 9 個數(shù)據(jù): A8 生產(chǎn)者 睡眠時間: 2消費者1消費一個數(shù)據(jù): A8 消費者1檢測到隊列數(shù)量: 0消費者1 睡眠時間: 4生產(chǎn)者正在存第 10 個數(shù)據(jù): A9 生產(chǎn)者 睡眠時間: 4消費者2消費一個數(shù)據(jù): A9 消費者2檢測到隊列數(shù)量: 0消費者2 睡眠時間: 5生產(chǎn)者正在存第 11 個數(shù)據(jù): A10 生產(chǎn)者 睡眠時間: 2消費者1消費一個數(shù)據(jù): A10 消費者1檢測到隊列數(shù)量: 0消費者1 睡眠時間: 3生產(chǎn)者正在存第 12 個數(shù)據(jù): A11 生產(chǎn)者 睡眠時間: 3消費者2消費一個數(shù)據(jù): A11 消費者2檢測到隊列數(shù)量: 0消費者2 睡眠時間: 3生產(chǎn)者正在存第 13 個數(shù)據(jù): A12 生產(chǎn)者 睡眠時間: 3消費者1消費一個數(shù)據(jù): A12 消費者1檢測到隊列數(shù)量: 0消費者1 睡眠時間: 3生產(chǎn)者正在存第 14 個數(shù)據(jù): A13 生產(chǎn)者 睡眠時間: 8消費者2消費一個數(shù)據(jù): A13 消費者2檢測到隊列數(shù)量: 0消費者2 睡眠時間: 7生產(chǎn)者正在存第 15 個數(shù)據(jù): A14 生產(chǎn)者 睡眠時間: 3消費者1消費一個數(shù)據(jù): A14 消費者1檢測到隊列數(shù)量: 0消費者1 睡眠時間: 7生產(chǎn)者正在存第 16 個數(shù)據(jù): A15 生產(chǎn)者 睡眠時間: 2消費者2消費一個數(shù)據(jù): A15 消費者2檢測到隊列數(shù)量: 0消費者2 睡眠時間: 9 |
從這個例子中，我們發(fā)現(xiàn)利用隊列，來做同步時非常簡單方便的，除此之外隊列，還有如下幾個方便的方法：
介紹一下此包中的常用方法:
|
1
2
3
4
5
6
7
8
9
10
|
Queue.qsize() 返回隊列的大小 Queue.empty() 如果隊列為空，返回True,反之FalseQueue.full() 如果隊列滿了，返回True,反之FalseQueue.full 與 maxsize 大小對應 Queue.get([block[, timeout]])獲取隊列，timeout等待時間 Queue.get_nowait() 相當Queue.get(False) 非阻塞 Queue.put(item) 寫入隊列，timeout等待時間 Queue.put_nowait(item) 相當Queue.put(item, False) Queue.task_done() 在完成一項工作之后，Queue.task_done()函數(shù)向任務已經(jīng)完成的隊列發(fā)送一個信號 Queue.join() 實際上意味著等到隊列為空，再執(zhí)行別的操作 |
以上就是詳解Python 模擬實現(xiàn)生產(chǎn)者消費者模式的實例，如有疑問請留言或者到本站社區(qū)交流討論，感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！
原文鏈接：http://qindongliang.iteye.com/blog/2115950
