1. //Demo1205.java
   
2. 
   
3. class Commodity//商品类
   
4. {
   
5.         private String name;
   
6.         private int count = 1;
   
7.         private boolean flag = false;
   
8. 
   
9.         public synchronized void Input(String name)
   
10.         {
    
11.                 this.name = name +"... ..."+count++;
    
12.                 while(true)
    
13.                 {
    
14.                         while (flag)
    
15.                         {       
    
16.                                 try
    
17.                                 {
    
18.                                         wait();
    
19.                                 }
    
20.                                 catch (Exception e)
    
21.                                 {
    
22.                                 }
    
23.                                 System.out.println(Thread.currentThread().getName()+"生产-->"+name);
    
24.                                 flag = !flag;
    
25.                                 notifyAll();
    
26.                         }
    
27.                 }
    
28.         }
    
29. 
    
30.         public synchronized void Output()
    
31.         {
    
32.                 while(true)
    
33.                 {
    
34.                         while (!flag)
    
35.                         {       
    
36.                                 try
    
37.                                 {
    
38.                                         wait();
    
39.                                 }
    
40.                                 catch (Exception e)
    
41.                                 {
    
42.                                 }
    
43.                                 System.out.println(Thread.currentThread().getName()+"消费------>"+name);
    
44.                                 flag = !flag;
    
45.                                 notifyAll();
    
46.                         }
    
47.                 }
    
48.         }
    
49. }
    
50. 
    
51. class PersonInput implements Runnable//生产类
    
52. {
    
53.         Commodity com;
    
54.         PersonInput(Commodity com)
    
55.         {
    
56.                 this.com = com;
    
57.         }
    
58.         public void run()
    
59.         {
    
60.                 com.Input("商品");
    
61.         }
    
62. 
    
63. }
    
64. 
    
65. class PersonOutput implements Runnable//消费类
    
66. {
    
67.         Commodity com;
    
68.         PersonOutput(Commodity com)
    
69.         {
    
70.                 this.com = com;
    
71.         }
    
72.         public void run()
    
73.         {
    
74.                 com.Output();       
    
75.         }
    
76. 
    
77. }
    
78. 
    
79. class Demo1205
    
80. {
    
81.         public static void main(String[] args)
    
82.         {
    
83.                 Commodity com = new Commodity();
    
84. 
    
85.                 PersonInput pi = new PersonInput(com);
    
86.                 PersonOutput po = new PersonOutput(com);
    
87. 
    
88.                 Thread t1 = new Thread(pi);
    
89.                 Thread t2 = new Thread(po);
    
90.                 t1.start();
    
91.                 t2.start();
    
92. 
    
93. //                System.out.println("Hello World!");
    
94.         }
    
95. }

复制代码

学习毕老师第12天课程写的这段代码，弄了两个小时了，老是一大堆错，现在不报错了，但是没有运行结果，朋友们帮我看看哪里出问题了。

//Demo1205.java

class Commodity//商品类
{
        private String name;
        private int count = 1;
        private boolean flag = false;

        public synchronized void Input(String name)
        {
                this.name = name +"... ..."+count++;
                while(true)
                {
                        while (flag)
                        {        
                                try
                                {
                                      wait();
                                }
                                catch (Exception e)
                                {
                                }
                                
                        }
                        System.out.println(Thread.currentThread().getName()+"生产-->"+name);//此句代码及以下应该写在while（flag）外面，否则，flag初始化为false，只能一直在外循环转悠了
                        flag = !flag;
                        notifyAll();
                }
        }

        public synchronized void Output()
        {
                while(true)
                {
                        while (!flag)
                        {        
                                try
                                {
                                        wait();
                                }
                                catch (Exception e)
                                {
                                }                                
                        }
                        System.out.println(Thread.currentThread().getName()+"消费------>"+name);//此处同上面一样
                        flag = !flag;
                        notifyAll();
                }
        }
}

class PersonInput implements Runnable//生产类
{
        Commodity com;
        PersonInput(Commodity com)
        {
                this.com = com;
        }
        public void run()
        {
                com.Input("商品");
        }

}

class PersonOutput implements Runnable//消费类
{
        Commodity com;
        PersonOutput(Commodity com)
        {
                this.com = com;
        }
        public void run()
        {
                com.Output();        
        }

}

class Demo1205
{
        public static void main(String[] args)
        {
                Commodity com = new Commodity();

                PersonInput pi = new PersonInput(com);
                PersonOutput po = new PersonOutput(com);

                Thread t1 = new Thread(pi);
                Thread t2 = new Thread(po);
                t1.start();
                t2.start();

//                System.out.println("Hello World!");
        }
}

谢谢啊，太爽了，鼻子都通气了。