问题描述
package thread;public class Producer_ConsumerTest {public static void main(String[] args) {SyncStack ss = new SyncStack();Thread producter = new Producter(ss);Thread consumer = new Consumer(ss);producter.start();consumer.start();}}class SyncStack {private int total = 0;private boolean flag = false;synchronized void product() {while(flag == true) {try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}total++;flag = true;this.notify();}synchronized int conmuse() {while(flag == false) {try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}total--;flag = false;this.notify();return total;}}class Producter extends Thread {SyncStack ss;Producter(SyncStack ss) {this.ss = ss;}public void run() {for(int i=1;i<10;i++) {ss.product();System.out.println("生产者" + Thread.currentThread().getName() + "生产了第" + i + "个商品,商品总数为");}}}class Consumer extends Thread {SyncStack ss;Consumer(SyncStack ss) {this.ss = ss;}public void run() {for(int i=1;i<10;i++) {ss.conmuse();System.out.println("消费者" + Thread.currentThread().getName() + "消费了第" + i + "个商品总数为");}}}-----------------我希望的输出结果是生产1个,然后消费1个,生产在前,但是达不到要求,目前实际输出是无序的,哪位朋友能帮忙修改一下吗? 问题补充:250846434 写道
解决方案
额。。发现一个问题this.notify(); 加在a()方法里面,return上面。
解决方案二:
synchronized int a(int i){total+=i;if(total==0){flag = false;}else{flag = true;}return total;}void product() {while (flag == true) {try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}a(1);}int conmuse() {while (flag == false) {try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}return a(-1);}我不知道咱俩理解的有误差没,我理解的大概是这样的啊
解决方案三:
额,生产和消费调用同一个同步方法,你现在是调用了两个。。。两个线程没有什么必然的联系。。应该是在conmuse和product中调用同一个同步方法来实现该功能,你现在无序的原因就是方法未结束,已经将flag的値给改变了。