黑马程序员技术交流社区

标题: 多线程死锁（notifyAll（））问题 [打印本页]
作者: EDDY_Liang    时间: 2014-6-16 19:09
标题: 多线程死锁（notifyAll（））问题


  2. //需求：生产烤鸭，生产者生产一份，消费者消费一份，
  3. //且生产者和消费者是多个。

  5. class Resourse
  6. {
  7.         String name;
  8.         int count=1;
  9.         boolean flag = false;
  10.         synchronized void producer()
  11.         {
  12.                
  13.                                 while(this.flag)
  14.                                         try{this.wait();}catch(InterruptedException e){}
  15.                                 System.out.println(Thread.currentThread().getName()+"生产烤鸭"+".........."+this.count);
  16.                                 this.flag = true;
  17.                                 this.notifyAll();

  19.                        
  20.        
  21.         }
  22.         synchronized void customer()
  23.         {
  24.                
  25.                                 while(!this.flag)
  26.                                         try{this.wait();}catch(InterruptedException e){}
  27.                                 System.out.println(Thread.currentThread().getName()+","+"xiaofei"+"..............................."+this.count);
  28.                                 this.flag = false;
  29.                                 this.count++;
  30.                                 this.notifyAll();
  31.                
  32.                        
  33.         }
  34. }
  35. class ShengChan implements Runnable
  36. {
  37.         Resourse r;
  38.         ShengChan(Resourse r)
  39.         {
  40.                 this.r = r;
  41.         }
  42.         public void run()
  43.         {
  44.                 r.producer();
  45.         }
  46. }
  47. class XiaoFei implements Runnable
  48. {
  49.         Resourse r;
  50.         XiaoFei(Resourse r)
  51.         {
  52.                 this.r = r;
  53.         }
  54.         public void run()
  55.         {
  56.                 r.customer();
  57.         }
  58. }


  61. class Test
  62. {
  63.         public static void main(String[] args)
  64.         {
  65.                 Resourse r = new Resourse();
  66.                 ShengChan a = new ShengChan(r);
  67.                 XiaoFei b = new XiaoFei(r);
  68.                 Thread t1 = new Thread(a);
  69.                 Thread t2 = new Thread(a);
  70.                 Thread t3 = new Thread(b);
  71.                 Thread t4 = new Thread(b);
  72.                 t1.start();
  73.                 t2.start();
  74.                 t3.start();
  75.                 t4.start();


  78.         }
  79. }
复制代码

为什么我这个多线程的问题，用notifyAll();了还是死锁啊，试了N次都是每个线程运行了一下。。求大神解答，谢谢
作者: 月光海    时间: 2014-6-16 19:26
没有死锁好不好，你的程序已经结束了，因为你把每个线程只运行了一次，如果要多次运行，请把资源类里的方法中加上循环
作者: 、海    时间: 2014-6-16 19:59
本帖最后由 、海 于 2014-6-16 20:21 编辑

//需求：生产烤鸭，生产者生产一份，消费者消费一份，
//且生产者和消费者是多个。

class Resourse
{
        String name;
        int count=1;
        boolean flag = false;
        synchronized void producer()
        {

                        
作者: 、海    时间: 2014-6-16 20:13
本帖最后由 、海 于 2014-6-16 20:29 编辑

                                while(true){//此处修改
                                     if(flag)  //此处修改        
                                         try{this.wait();}catch(InterruptedException e){}
                                     System.out.println(Thread.currentThread().getName()+"生产烤鸭"+".........."+this.count);
                                } //此处修改
                                this.flag = true;
                                this.notifyAll();

                        
        
        }
作者: 、海    时间: 2014-6-16 20:15
本帖最后由 、海 于 2014-6-16 20:29 编辑

       synchronized void customer(){
               while(true){//此处修改
                          if(!this.flag)//此处修改
                                        try{this.wait();}catch(InterruptedException e){}
                           System.out.println(Thread.currentThread().getName()+","+"xiaofei"+"..............................."+this.count);
                }//此处修改
                this.flag = false;
                this.count++;
                this.notifyAll();        }
}








欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2