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();`
建议使用生产者消费者模型
这样效果更直观
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。