wait和notify實(shí)現(xiàn)生產(chǎn)者消費(fèi)者
實(shí)例
數(shù)據(jù)對(duì)象
/**
* 數(shù)據(jù)對(duì)象
*/
public class Data {
private List<String> list = new ArrayList<>();
synchronized public void push(String data) {
try {
while (list.size() != 0) {
this.wait();
}
list.add(data);
this.notify();
System.out.println("push: " + list.size());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
synchronized public String pop() {
String result = "";
try {
while (list.size() == 0) {
this.wait();
}
result = list.get(0);
list.remove(0);
this.notify();
System.out.println("pop: " + list.size());
} catch (InterruptedException e) {
e.printStackTrace();
}
return result;
}
}
生產(chǎn)者
/**
* 生產(chǎn)者
*/
public class Producer implements Runnable {
private Data data;
public Producer(Data data) {
this.data = data;
}
public void service() {
data.push("random=" + Math.random());
}
@Override
public void run() {
while (true) {
service();
}
}
}
消費(fèi)者
/**
* 消費(fèi)者
*/
public class Consumer implements Runnable {
private Data data;
public Consumer(Data data) {
this.data = data;
}
public void service() {
System.out.println("pop: " + data.pop());
}
@Override
public void run() {
while (true) {
service();
}
}
}
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
