概述
對于多線程程序來說，生產(chǎn)者和消費者模型是非常經(jīng)典的模型。更加準(zhǔn)確的說，應(yīng)該叫“生產(chǎn)者-消費者-倉庫模型”。離開了倉庫，生產(chǎn)者、消費者就缺少了共用的存儲空間，也就不存在并非協(xié)作的問題了。
示例
定義一個場景。一個倉庫只允許存放10件商品，生產(chǎn)者每次可以向其中放入一個商品，消費者可以每次從其中取出一個商品。同時，需要注意以下4點：
1. 同一時間內(nèi)只能有一個生產(chǎn)者生產(chǎn)，生產(chǎn)方法需要加鎖synchronized。
2. 同一時間內(nèi)只能有一個消費者消費，消費方法需要加鎖synchronized。
3. 倉庫為空時，消費者不能繼續(xù)消費。消費者消費前需要循環(huán)判斷當(dāng)前倉庫狀態(tài)是否為空，空的話則消費線程需要wait，釋放鎖允許其他同步方法執(zhí)行。
4. 倉庫為滿時，生產(chǎn)者不能繼續(xù)生產(chǎn)，生產(chǎn)者生產(chǎn)錢需要循環(huán)判斷當(dāng)前倉庫狀態(tài)是否為滿，滿的話則生產(chǎn)線程需要wait，釋放鎖允許其他同步方法執(zhí)行。
示例代碼如下：
|
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
|
public class Concurrence { public static void main(String[] args) { WareHouse wareHouse = new WareHouse(); Producer producer = new Producer(wareHouse); Consumer consumer = new Consumer(wareHouse); new Thread(producer).start(); new Thread(consumer).start(); } } class WareHouse { private static final int STORE_SIZE = 10; private String[] storeProducts = new String[STORE_SIZE]; private int index = 0; public void pushProduct(String product) { synchronized (this) { while (index == STORE_SIZE) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } storeProducts[index++] = product; this.notify(); System.out.println("生產(chǎn)了: " + product + " , 目前倉庫里共: " + index + " 個貨物"); } } public synchronized String getProduct() { synchronized (this) { while (index == 0) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } String product = storeProducts[index - 1]; index--; System.out.println("消費了: " + product + ", 目前倉庫里共: " + index + " 個貨物"); this.notify(); return product; } } } class Producer implements Runnable { WareHouse wareHouse; public Producer(WareHouse wh) { this.wareHouse = wh; } @Override public void run() { for (int i = 0; i < 40; i++) { String product = "product" + i; this.wareHouse.pushProduct(product); } } } class Consumer implements Runnable { WareHouse wareHouse; public Consumer(WareHouse wh) { this.wareHouse = wh; } @Override public void run() { for (int i = 0; i < 40; i++) { this.wareHouse.getProduct(); } } } |
