散仙使用python3.4模擬實現的一個生產者與消費者的例子，用到的知識有線程，隊列，循環等，源碼如下：
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) #生產者 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,"個數據: ",d) #q.put("A"+str(i),False,2000) q.put(d) print("生產完畢!") #消費者 def co(): name=threading.current_thread().getName() time.sleep(1) print(name+"線程啟動......") while True: print(name+"檢測到隊列數量: ",q.qsize()) t=random.randint(2,9) print(name,"睡眠時間: ",t) data=q.get(); print(name+"消費一個數據: ",data) p=threading.Thread(target=pr,name="生產者") c=threading.Thread(target=co,name="消費者1") c2=threading.Thread(target=co,name="消費者2") p.start() c.start() c2.start() |
在本例里面散仙啟動了1個生產者線程，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
|
生產者線程啟動...... 生產者 睡眠時間: 4消費者1線程啟動...... 消費者1檢測到隊列數量: 0消費者1 睡眠時間: 2消費者2線程啟動...... 消費者2檢測到隊列數量: 0消費者2 睡眠時間: 3生產者正在存第 1 個數據: A0 生產者 睡眠時間: 9消費者1消費一個數據: A0 消費者1檢測到隊列數量: 0消費者1 睡眠時間: 8生產者正在存第 2 個數據: A1 生產者 睡眠時間: 5消費者2消費一個數據: A1 消費者2檢測到隊列數量: 0消費者2 睡眠時間: 7生產者正在存第 3 個數據: A2 生產者 睡眠時間: 8消費者1消費一個數據: A2 消費者1檢測到隊列數量: 0消費者1 睡眠時間: 2生產者正在存第 4 個數據: A3 生產者 睡眠時間: 7消費者2消費一個數據: A3 消費者2檢測到隊列數量: 0消費者2 睡眠時間: 9生產者正在存第 5 個數據: A4 生產者 睡眠時間: 2消費者1消費一個數據: A4 消費者1檢測到隊列數量: 0消費者1 睡眠時間: 5生產者正在存第 6 個數據: A5 生產者 睡眠時間: 5消費者2消費一個數據: A5 消費者2檢測到隊列數量: 0消費者2 睡眠時間: 6生產者正在存第 7 個數據: A6 生產者 睡眠時間: 7消費者1消費一個數據: A6 消費者1檢測到隊列數量: 0消費者1 睡眠時間: 7生產者正在存第 8 個數據: A7 生產者 睡眠時間: 3消費者2消費一個數據: A7 消費者2檢測到隊列數量: 0消費者2 睡眠時間: 8生產者正在存第 9 個數據: A8 生產者 睡眠時間: 2消費者1消費一個數據: A8 消費者1檢測到隊列數量: 0消費者1 睡眠時間: 4生產者正在存第 10 個數據: A9 生產者 睡眠時間: 4消費者2消費一個數據: A9 消費者2檢測到隊列數量: 0消費者2 睡眠時間: 5生產者正在存第 11 個數據: A10 生產者 睡眠時間: 2消費者1消費一個數據: A10 消費者1檢測到隊列數量: 0消費者1 睡眠時間: 3生產者正在存第 12 個數據: A11 生產者 睡眠時間: 3消費者2消費一個數據: A11 消費者2檢測到隊列數量: 0消費者2 睡眠時間: 3生產者正在存第 13 個數據: A12 生產者 睡眠時間: 3消費者1消費一個數據: A12 消費者1檢測到隊列數量: 0消費者1 睡眠時間: 3生產者正在存第 14 個數據: A13 生產者 睡眠時間: 8消費者2消費一個數據: A13 消費者2檢測到隊列數量: 0消費者2 睡眠時間: 7生產者正在存第 15 個數據: A14 生產者 睡眠時間: 3消費者1消費一個數據: A14 消費者1檢測到隊列數量: 0消費者1 睡眠時間: 7生產者正在存第 16 個數據: A15 生產者 睡眠時間: 2消費者2消費一個數據: A15 消費者2檢測到隊列數量: 0消費者2 睡眠時間: 9 |
從這個例子中，我們發現利用隊列，來做同步時非常簡單方便的，除此之外隊列，還有如下幾個方便的方法：
介紹一下此包中的常用方法:
|
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()函數向任務已經完成的隊列發送一個信號 Queue.join() 實際上意味著等到隊列為空，再執行別的操作 |
以上就是詳解Python 模擬實現生產者消費者模式的實例，如有疑問請留言或者到本站社區交流討論，感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！
原文鏈接：http://qindongliang.iteye.com/blog/2115950
