本文實(shí)例講述了java基于lock的生產(chǎn)者消費(fèi)者模型。分享給大家供大家參考，具體如下：
前面一篇《java鎖機(jī)制lock用法》簡(jiǎn)單介紹了鎖機(jī)制，這里進(jìn)一步分析一下基于lock的生產(chǎn)者消費(fèi)者模型。
|
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
89
90
91
|
package com.expgiga.juc;import java.util.concurrent.locks.condition;import java.util.concurrent.locks.lock;import java.util.concurrent.locks.reentrantlock;/** * 生產(chǎn)者消費(fèi)者案例 */public class testproductorandconsumerforlock { public static void main(string[] args) { clerk clerk = new clerk(); productor productor = new productor(clerk); consumer consumer = new consumer(clerk); new thread(productor, "生產(chǎn)者a").start(); new thread(consumer, "消費(fèi)者b").start(); new thread(productor, "生產(chǎn)者c").start(); new thread(consumer, "消費(fèi)者d").start(); }}//店員class clerk { private int product = 0; private lock lock = new reentrantlock(); private condition condition = lock.newcondition(); //進(jìn)貨方法 public void get() { lock.lock(); try { while (product >= 1) { //為了避免虛假喚醒，應(yīng)該總是使用在循環(huán)中 system.out.println("產(chǎn)品已滿！"); try { condition.await(); } catch (interruptedexception e) { e.printstacktrace(); } } system.out.println(thread.currentthread().getname() + " : " + ++product); condition.signalall(); } finally { lock.unlock(); } } //賣貨方法 public void sale() { lock.lock(); try { while (product <= 0) { system.out.println("產(chǎn)品缺貨！"); try { condition.await(); } catch (interruptedexception e) { e.printstacktrace(); } } system.out.println(thread.currentthread().getname() + " : " + --product); condition.signalall(); } finally { lock.unlock(); } }}//生產(chǎn)者class productor implements runnable { private clerk clerk; public productor(clerk clerk) { this.clerk = clerk; } @override public void run() { for (int i = 0; i < 20; i++) { try { thread.sleep(200); } catch (interruptedexception e) { e.printstacktrace(); } clerk.get(); } }}//消費(fèi)者class consumer implements runnable { private clerk clerk; public consumer(clerk clerk) { this.clerk = clerk; } @override public void run() { for (int i = 0; i < 20; i++) { clerk.sale(); } }} |
運(yùn)行結(jié)果：
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者a : 1
產(chǎn)品已滿！
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者c : 1
產(chǎn)品已滿！
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者b : 0
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者c : 1
消費(fèi)者d : 0
產(chǎn)品缺貨！
生產(chǎn)者a : 1
消費(fèi)者d : 0
希望本文所述對(duì)大家java程序設(shè)計(jì)有所幫助。
原文鏈接：https://blog.csdn.net/u013063153/article/details/76407240
