package com.thread.tongbu;
public class Buffer {
private int value;
private boolean isEmpty=true;
public synchronized void put(int i) {
while(!this.isEmpty)
try {
this.wait();
} catch (InterruptedException e) {}
this.value=i;
this.isEmpty=false;
this.notify();
}
public synchronized int get() {
while(this.isEmpty)
try {
this.wait();
} catch (InterruptedException e) {}
this.isEmpty=true;
this.notify();
return this.value;
}
public static void main(String args[]) {
Buffer buffer=new Buffer();
(new SendThread(buffer)).start();
(new ReceiveThread(buffer)).start();
}
}
public class SendThread extends Thread {
private Buffer buffer;
public SendThread(Buffer buffer){
this.buffer=buffer;
}
public void run(){
for(int i=1;i<5;i++){
buffer.put(i);
System.out.println(this.getClass().getName()+"put:"+i);
}
}
}
public class ReceiveThread extends Thread {
private Buffer buffer;
public ReceiveThread(Buffer buffer) {
this.buffer=buffer;
}
public void run() {
for(int i=1;i<5;i++){
System.out.println("\t\t\t\t"+this.getClass().getName()+"get:"+buffer.get());
}
}
}
感覺代碼沒錯啊 但是結果總是不正確
這是一個典型的 single threaded pattern。
和生產者消費者模型還是有區別的。畢竟只是一個empty,不是一個列表
程序是沒有問題的。
您是感覺輸出結果不像是線程那種隨機的感覺吧。
你的輸出結果規律性太強是不?
主要有2點原因:
1--如果你不put,那麼get的線程就一直等。關鍵就是一個empty的控制。
如果你使用的是一個隊列,那麼效果可能會改變。
2--沒有引入隨機控制
a.給sendThread和receivethtread類加入私有成員變量
private Random random;
b.修改2個類的構造函數,以Send的線程為例
public SendThread(Buffer buffer,long seed){
this.buffer=buffer;
this.random = new Random(seed);
}
c.修改run方法,在末尾加上如下代碼
try {
Thread.sleep(this.random.nextInt(1000));
} catch (InterruptedException e) {
e.printStackTrace();
}
d.修改main方法
(new SendThread(buffer,3141592L)).start();
(new ReceiveThread(buffer,6535897L)).start();
建議使用生產者消費者模型
這樣效果更直觀