A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始


//为什么,会没有结果,死锁吗?


class Resourse{

        private String name;
        private int num = 1;
        private boolean flag;

        public synchronized void set(String name){
       
                if(flag){
               
                        try{this.wait();} catch(InterruptedException e) {}
                }

                else{
               
                        this.name = name+num;
                        num++;

                        System.out.println(Thread.currentThread().getName()+"***生产者***"+this.name);

                        flag = true;
                        this.notify();
                }
        }

        public synchronized void get(){
       
                if(flag){
               
                        try{this.wait();}catch(InterruptedException e){}
                }

                else{

                        System.out.println(Thread.currentThread().getName()+"...消费者..."+this.name);

                        flag = false;
                        this.notify();
                }

        }
}

class Produce implements Runnable{

        Resourse r;

        public Produce(Resourse r){
       
                this.r = r;
        }

        public void run(){

                while(true){
               
                        r.set("馒头");
               
                }
        }
}

class Consumer implements Runnable{

        Resourse r;

        public Consumer(Resourse r){
       
                this.r = r;
        }

        public void run(){
       
                while(true){
               
                        r.get();
                }
        }
}

public class Show{

        public static void main(String[] args){
       
                Resourse r = new Resourse();

                Produce p = new Produce(r);
                Consumer c = new Consumer(r);

                Thread t1 = new Thread(p);
                Thread t2 = new Thread(c);

                t1.start();
                t2.start();
        }
}


1 个回复

倒序浏览
看了半天终于找到了,在get()方法中的if()语句应该写成if(!flag)  ,
写成if(flag)导致set方法生产一个后flag改成true,生产者等待,然后消费者去判断为true也等待,导致线程全部等待,但不是死锁。。
另外小建议将notify()改为notifyAll(),这样多个生产者和消费者线程去操作时就不会产生线程全部等待的现象。notify()只是唤醒线程池中第一个等待的线程。
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马