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();
                }
               
        }
       
}
各位大侠麻烦帮忙看一下，我看着视频敲的，也不知道哪里出了问题，多线程执行控制台没有反应，也不报错？？谢谢！

1. public class ProductDemo {
   
2. 
   
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();
    
21. 
    
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. }
    
64. 
    
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. }
    
80. 
    
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. }

复制代码

改正在源代码，呵呵  记得要细心啊

1. 修改后的正确代码如下：
   
2. 
   
3. public class test {
   
4. 
   
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();
    
23. 
    
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. }
    
68. 
    
69. class Producter implements Runnable{
    
70. private Resource res;
    
71. Producter(Resource res){
    
72.          this.res=res;
    
73. }
    
74. 
    
75.     @Override
    
76.     public void run() {
    
77.             while(true){
    
78.                        res.set("北京烤鸭");
    
79.             }
    
80.             
    
81.     }
    
82.    
    
83. }
    
84. 
    
85. class Consumer implements Runnable{
    
86. private Resource res;
    
87. 
    
88. Consumer(Resource res){
    
89.         this.res=res;
    
90. }
    
91. 
    
92.     @Override
    
93.     public void run() {
    
94.             while(true){
    
95.                        res.Out();
    
96.             }
    
97.             
    
98.     }
    
99.    
    
100. }
     
101. 
     
102. if语句都应该改成while语句来判断！！！！，另外你的while语句括号的范围错了。

复制代码

多谢楼主啦，:handshake原来这里的while循环不用带{ }括号，编程习惯都加了，去掉果然可以打印，不过后面的if()判断也可以打印出来，只不过数据乱的，改成while确实正常啦。。。。。

修改后的正确代码如下：

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();
            }
            
    }
   
}