黑马程序员技术交流社区

标题: Java多线程，多生产者多消费者模式 [打印本页]
作者: 大漠孤烟    时间: 2014-5-1 23:11
标题: Java多线程，多生产者多消费者模式
package com.itheima.thread.demo;

public class ProductDemo {

        /**
         * @param args
         */
        public static void main(String[] args) {
                Resource res=new Resource();
               
                Producter pd=new Producter(res);
                Consumer cos=new Consumer(res);
               
                Thread t1=new Thread(pd);
                Thread t2=new Thread(pd);
                Thread t3=new Thread(cos);
                Thread t4=new Thread(cos);
               
                t1.start();
                t2.start();
                t3.start();
                t4.start();

        }
}
class Resource{
               
                private String name;
                private int count=1;
                private static boolean flag=false;
                //生产
          public synchronized void set(String name){
                 
                   while(flag){
                           try {
                                this.wait();
                        } catch (Exception e) {
                                // TODO: handle exception
                        }
                           this.name=name+"..."+count++; //烤鸭1、烤鸭2、烤鸭3
                          
                           System.out.print(Thread.currentThread().getName()+"......生产者.."+this.name);
                          
                           flag=true;
                           notifyAll(); //唤醒所有等待的线程
                          
                   }
         
         }
         //消费
         public synchronized  void Out (){
                 if(!flag)
                           try {
                                   wait();
                                } catch (Exception e) {
                                        // TODO: handle exception
                                }
                 
                 System.out.print(Thread.currentThread().getName()+"......消费者..."+this.name);
                 flag=false;
                 notifyAll();
                 
         }
         
}

class Producter implements Runnable{
     private Resource res;
     Producter(Resource res){
             this.res=res;
     }
     
        @Override
        public void run() {
                while(true){
                           res.set("北京烤鸭");
                }
               
        }
       
}

class Consumer implements Runnable{
    private Resource res;
   
    Consumer(Resource res){
            this.res=res;
    }
   
        @Override
        public void run() {
                while(true){
                           res.Out();
                }
               
        }
       
}
各位大侠麻烦帮忙看一下，我看着视频敲的，也不知道哪里出了问题，多线程执行控制台没有反应，也不报错？？谢谢！
作者: Up↑Lee↗    时间: 2014-5-2 08:54
  1. public class ProductDemo {

  3.         /**
  4.          * @param args
  5.          */
  6.         public static void main(String[] args) {
  7.                 Resource res=new Resource();
  8.                
  9.                 Producter pd=new Producter(res);
  10.                 Consumer cos=new Consumer(res);
  11.                
  12.                 Thread t1=new Thread(pd);
  13.                 Thread t2=new Thread(pd);
  14.                 Thread t3=new Thread(cos);
  15.                 Thread t4=new Thread(cos);
  16.                
  17.                 t1.start();
  18.                 t2.start();
  19.                 t3.start();
  20.                 t4.start();

  22.         }
  23. }
  24. class Resource{
  25.                
  26.                 private String name;
  27.                 private int count=1;
  28.                 private static boolean flag=false;
  29.                 //生产
  30.           public synchronized void set(String name){
  31.                  
  32.                    while(flag)  //-<span style="background-color: yellow;">----------------------你把while的{}去掉就可以了    加上{}没有再次判断条件</span>
  33.                            try {
  34.                                 this.wait();
  35.                         } catch (Exception e) {
  36.                                 // TODO: handle exception
  37.                         }
  38.                            this.name=name+"..."+count++; //烤鸭1、烤鸭2、烤鸭3
  39.                            
  40.                            System.out.println(Thread.currentThread().getName()+"......生产者.."+this.name);/<span style="background-color: yellow;">/------记得换行</span>
  41.                            
  42.                            flag=true;
  43.                            notifyAll(); //唤醒所有等待的线程
  44.                            
  45.                   
  46.          
  47.          }
  48.          //消费
  49.          public synchronized  void Out (){
  50.                  if(!flag)
  51.                            try {
  52.                                    wait();
  53.                                 } catch (Exception e) {
  54.                                         // TODO: handle exception
  55.                                 }
  56.                  
  57.                  System.out.println(Thread.currentThread().getName()+"......消费者..."+this.name);
  58.                  flag=false;
  59.                  notifyAll();
  60.                  
  61.          }
  62.          
  63. }

  65. class Producter implements Runnable{
  66.      private Resource res;
  67.      Producter(Resource res){
  68.              this.res=res;
  69.      }
  70.      
  71.         @Override
  72.         public void run() {
  73.                 while(true){
  74.                            res.set("北京烤鸭");
  75.                 }
  76.                
  77.         }
  78.         
  79. }

  81. class Consumer implements Runnable{
  82.     private Resource res;
  83.    
  84.     Consumer(Resource res){
  85.             this.res=res;
  86.     }
  87.    
  88.         @Override
  89.         public void run() {
  90.                 while(true){
  91.                            res.Out();
  92.                 }
  93.                
  94.         }
  95.         
  96. }
复制代码
改正在源代码，呵呵  记得要细心啊

作者: Lin0411    时间: 2014-5-2 10:01
  1. 修改后的正确代码如下：

  3. public class test {

  5.     /**
  6.      * @param args
  7.      */
  8.     public static void main(String[] args) {
  9.             Resource res=new Resource();
  10.             
  11.             Producter pd=new Producter(res);
  12.             Consumer cos=new Consumer(res);
  13.             
  14.             Thread t1=new Thread(pd);
  15.             Thread t2=new Thread(pd);
  16.             Thread t3=new Thread(cos);
  17.             Thread t4=new Thread(cos);
  18.             
  19.             t1.start();
  20.             t2.start();
  21.             t3.start();
  22.             t4.start();

  24.     }
  25. }
  26. class Resource{
  27.             
  28.             private String name;
  29.             private int count=1;
  30.             private static boolean flag=false;
  31.             //生产
  32.      public synchronized void set(String name){
  33.             
  34.                while(flag){
  35.                        try {
  36.                             this.wait();
  37.                     } catch (Exception e) {
  38.                             // TODO: handle exception
  39.                     }
  40.                       }
  41.                        this.name=name+"..."+count++; //烤鸭1、烤鸭2、烤鸭3
  42.                        
  43.                        System.out.println(Thread.currentThread().getName()+"......生产者.."+this.name);
  44.                        
  45.                        flag=true;
  46.                        notifyAll(); //唤醒所有等待的线程
  47.                      
  48.                
  49.      
  50.      }
  51.      //消费
  52.     public synchronized  void Out (){
  53.              while(!flag)
  54.                        {try {
  55.                                wait();
  56.                             } catch (Exception e) {
  57.                                     // TODO: handle exception
  58.                             }
  59.                        }
  60.             
  61.              System.out.println(Thread.currentThread().getName()+"......消费者..."+this.name);
  62.              flag=false;
  63.              notifyAll();
  64.             
  65.      }
  66.      
  67. }

  69. class Producter implements Runnable{
  70. private Resource res;
  71. Producter(Resource res){
  72.          this.res=res;
  73. }

  75.     @Override
  76.     public void run() {
  77.             while(true){
  78.                        res.set("北京烤鸭");
  79.             }
  80.             
  81.     }
  82.    
  83. }

  85. class Consumer implements Runnable{
  86. private Resource res;

  88. Consumer(Resource res){
  89.         this.res=res;
  90. }

  92.     @Override
  93.     public void run() {
  94.             while(true){
  95.                        res.Out();
  96.             }
  97.             
  98.     }
  99.    
  100. }

  102. if语句都应该改成while语句来判断！！！！，另外你的while语句括号的范围错了。
复制代码
作者: 大漠孤烟    时间: 2014-5-2 23:47
多谢楼主啦，:handshake原来这里的while循环不用带{ }括号，编程习惯都加了，去掉果然可以打印，不过后面的if()判断也可以打印出来，只不过数据乱的，改成while确实正常啦。。。。。
作者: 邵景伦    时间: 2014-5-3 16:20
修改后的正确代码如下：

public class test {

    /**
     * @param args
     */
    public static void main(String[] args) {
            Resource res=new Resource();
            
            Producter pd=new Producter(res);
            Consumer cos=new Consumer(res);
            
            Thread t1=new Thread(pd);
            Thread t2=new Thread(pd);
            Thread t3=new Thread(cos);
            Thread t4=new Thread(cos);
            
            t1.start();
            t2.start();
            t3.start();
            t4.start();

    }
}
class Resource{
            
            private String name;
            private int count=1;
            private static boolean flag=false;
            //生产
     public synchronized void set(String name){
            
               while(flag){//范围错误
                       try {
                            this.wait();
                    } catch (Exception e) {
                            // TODO: handle exception
                    }
                      }
                       this.name=name+"..."+count++; //烤鸭1、烤鸭2、烤鸭3
                       
                       System.out.println(Thread.currentThread().getName()+"......生产者.."+this.name);
                       
                       flag=true;
                       notifyAll(); //唤醒所有等待的线程
                     
               
     
     }
     //消费
    public synchronized  void Out (){
             while(!flag)
                       {try {
                               wait();
                            } catch (Exception e) {
                                    // TODO: handle exception
                            }
                       }
            
             System.out.println(Thread.currentThread().getName()+"......消费者..."+this.name);
             flag=false;
             notifyAll();
            
     }
     
}

class Producter implements Runnable{
private Resource res;
Producter(Resource res){
         this.res=res;
}

    @Override
    public void run() {
            while(true){//修改后if换成while
                       res.set("北京烤鸭");
            }
            
    }
   
}

class Consumer implements Runnable{
private Resource res;

Consumer(Resource res){
        this.res=res;
}

    @Override
    public void run() {
            while(true){
                       res.Out();
            }
            
    }
   
}





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