1. //producer：生产者，制片人        consumer：消费者，用户
   
2. class ProducerConsumerDemo
   
3. {
   
4.         public static void main(String[] args)
   
5.         {
   
6.                 //创建resource对象
   
7.                 Resource res = new Resource();
   
8.                 //创建producer对象
   
9.                 Producer pro = new Producer(res);
   
10.                 //创建Consumer对象
    
11.                 Consumer con = new Consumer(res);
    
12.                 //创建4个线程
    
13.                 Thread t1 = new Thread(pro);
    
14.                 Thread t2 = new Thread(con);
    
15.                 Thread t3 = new Thread(pro);
    
16.                 Thread t4 = new Thread(con);
    
17.                 //启动四个线程
    
18.                 t1.start();
    
19.                 t2.start();
    
20.                 t3.start();
    
21.                 t4.start();
    
22.         }
    
23. }
    
24. 
    
25. //resource:资源
    
26. class Resource
    
27. {
    
28.         //私有的产品名称
    
29.         private String name;
    
30.         //私有的计数器，产品编号
    
31.         private int count = 1;
    
32.         //布尔型变量,用于判断线程要执行哪里
    
33.         private boolean flag = false;
    
34.        
    
35.         //加同步锁的set，设置产品名称的方法。
    
36.         public synchronized void set(String name)
    
37.         {
    
38.                 while(true)
    
39.                 {
    
40.                         //判断flag是否真
    
41.         //                if (flag)
    
42.                         //while循环判断,当线程被解除冻结后需要回来再判断一次
    
43.                         while (flag)
    
44. 
    
45.                         {
    
46.                                 //wait：等待，把当前线程冻结起来。等待notify（通知，告知）唤醒，notifyAll：唤醒全部线程
    
47.                                 try{wait();}catch(Exception e){}
    
48.                         }
    
49.                         //把传入的name加上计数器赋值给本类的name
    
50.                         this.name = name+"+==+"+count++;
    
51. 
    
52.                         //打印当前线程name和当前生产者的name
    
53.                         System.out.println(Thread.currentThread().getName()+".生产者.SS."+this.name);
    
54.                         //把flag的值改为true。
    
55.                         flag = true;
    
56.                         //唤醒第一个冻结的线程
    
57.         //                this.notify();
    
58.                         //唤醒所有线程
    
59.                         this.notifyAll();
    
60.                 }
    
61.         }
    
62. 
    
63.         //输出函数，输出产品名称和编号
    
64.         public synchronized void out()
    
65.         {
    
66.                 while(true)
    
67.                 {
    
68.                         //if判断flag是否为false,线程被唤醒后继续执行，不再回来判断
    
69.         //                if (!flag)
    
70.                         //while循环判断,当线程被解除冻结后需要回来再判断一次
    
71.                         while (!flag)
    
72.                         {
    
73.                                 //flag为false时，线程进入等待状态，没有执行资格，等待唤醒
    
74.                                 try{wait();}catch(Exception e){}
    
75.                         }
    
76.                         //打印当前线程名称和购买者名称
    
77.                         System.out.println(Thread.currentThread().getName()+".购买者.GOGOGO."+this.name);
    
78.                         //修改flag的值为false；
    
79.                         flag = false;;
    
80.                         //唤醒最先冻结的线程
    
81.         //                this.notify();
    
82.                         //唤醒所有线程
    
83.                         this.notifyAll();
    
84.                 }
    
85.         }
    
86. }
    
87. 
    
88. //创建类producer，实现多线程Runnable接口。
    
89. class Producer implements Runnable
    
90. {
    
91.         //建立resource引用
    
92.         private Resource res;
    
93.         //初始化引用
    
94.         Producer(Resource res)
    
95.         {
    
96.                 //把引用指向类resource
    
97.                 this.res = res;
    
98.         }
    
99.        
    
100.         //复写run方法
     
101.         public void run()
     
102.         {
     
103. //                while(true)
     
104. //                {
     
105.                         //调用set函数，对产品名称进行设置
     
106.                         res.set("雀氏挖掘机");
     
107. //                }
     
108.         }
     
109. 
     
110. }
     
111. 
     
112. class Consumer implements Runnable
     
113. {
     
114.         //建立引用
     
115.         private Resource res;
     
116.         //初始化
     
117.         Consumer(Resource res)
     
118.         {
     
119.                 //res赋值
     
120.                 this.res = res;
     
121.         }
     
122. 
     
123.         //复写run函数
     
124.         public void run()
     
125.         {
     
126. //                while(true)
     
127. //                {
     
128.                         //调用out函数。
     
129.                         res.out();
     
130. //                }
     
131.         }
     
132. }

复制代码

写完这个，听到毕老师说：啊，这个下节课给你们画图演示一下啊！
到了下节课。只看到画面上画好的一张有着勾勾叉叉的图就在那儿放着。。。。

然后毕老师说：
       这个，咳咳。图已经画好了，你们那个、、心里明白怎么画的啊。。我就不说了
。。。。。。然后毕老师的阴笑声：嘿嘿。。那个，看视频的同学可能不知道，来给你们看一下啊、、。。。。。。。。=====================         0.0  0.0   0.0   0.0   0.0

我闭目深呼吸，抬头，食指指向天空，然后厉声大吼道：毕老师你就可劲坑吧！
:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(

1. //producer：生产者，制片人        consumer：消费者，用户
   
2. class ProducerConsumerDemo
   
3. {
   
4.         public static void main(String[] args)
   
5.         {
   
6.                 //创建resource对象
   
7.                 Resource res = new Resource();
   
8.                 //创建producer对象
   
9.                 Producer pro = new Producer(res);
   
10.                 //创建Consumer对象
    
11.                 Consumer con = new Consumer(res);
    
12.                 //创建4个线程
    
13.                 Thread t1 = new Thread(pro);
    
14.                 Thread t2 = new Thread(con);
    
15.                 Thread t3 = new Thread(pro);
    
16.                 Thread t4 = new Thread(con);
    
17.                 //启动四个线程
    
18.                 t1.start();
    
19.                 t2.start();
    
20.                 t3.start();
    
21.                 t4.start();
    
22.         }
    
23. }
    
24. 
    
25. //resource:资源
    
26. class Resource
    
27. {
    
28.         //私有的产品名称
    
29.         private String name;
    
30.         //私有的计数器，产品编号
    
31.         private int count = 1;
    
32.         //布尔型变量,用于判断线程要执行哪里
    
33.         private boolean flag = false;
    
34.        
    
35.         //加同步锁的set，设置产品名称的方法。
    
36.         public synchronized void set(String name)
    
37.         {
    
38.                 while(true)
    
39.                 {
    
40.                         //判断flag是否真
    
41.         //                if (flag)
    
42.                         //while循环判断,当线程被解除冻结后需要回来再判断一次
    
43.                         while (flag)
    
44. 
    
45.                         {
    
46.                                 //wait：等待，把当前线程冻结起来。等待notify（通知，告知）唤醒，notifyAll：唤醒全部线程
    
47.                                 try{wait();}catch(Exception e){}
    
48.                         }
    
49.                         //把传入的name加上计数器赋值给本类的name
    
50.                         this.name = name+"+==+"+count++;
    
51. 
    
52.                         //打印当前线程name和当前生产者的name
    
53.                         System.out.println(Thread.currentThread().getName()+".生产者.SS."+this.name);
    
54.                         //把flag的值改为true。
    
55.                         flag = true;
    
56.                         //唤醒第一个冻结的线程
    
57.         //                this.notify();
    
58.                         //唤醒所有线程
    
59.                         this.notifyAll();
    
60.                 }
    
61.         }
    
62. 
    
63.         //输出函数，输出产品名称和编号
    
64.         public synchronized void out()
    
65.         {
    
66.                 while(true)
    
67.                 {
    
68.                         //if判断flag是否为false,线程被唤醒后继续执行，不再回来判断
    
69.         //                if (!flag)
    
70.                         //while循环判断,当线程被解除冻结后需要回来再判断一次
    
71.                         while (!flag)
    
72.                         {
    
73.                                 //flag为false时，线程进入等待状态，没有执行资格，等待唤醒
    
74.                                 try{wait();}catch(Exception e){}
    
75.                         }
    
76.                         //打印当前线程名称和购买者名称
    
77.                         System.out.println(Thread.currentThread().getName()+".购买者.GOGOGO."+this.name);
    
78.                         //修改flag的值为false；
    
79.                         flag = false;;
    
80.                         //唤醒最先冻结的线程
    
81.         //                this.notify();
    
82.                         //唤醒所有线程
    
83.                         this.notifyAll();
    
84.                 }
    
85.         }
    
86. }
    
87. 
    
88. //创建类producer，实现多线程Runnable接口。
    
89. class Producer implements Runnable
    
90. {
    
91.         //建立resource引用
    
92.         private Resource res;
    
93.         //初始化引用
    
94.         Producer(Resource res)
    
95.         {
    
96.                 //把引用指向类resource
    
97.                 this.res = res;
    
98.         }
    
99.        
    
100.         //复写run方法
     
101.         public void run()
     
102.         {
     
103. //                while(true)
     
104. //                {
     
105.                         //调用set函数，对产品名称进行设置
     
106.                         res.set("雀氏挖掘机");
     
107. //                }
     
108.         }
     
109. 
     
110. }
     
111. 
     
112. class Consumer implements Runnable
     
113. {
     
114.         //建立引用
     
115.         private Resource res;
     
116.         //初始化
     
117.         Consumer(Resource res)
     
118.         {
     
119.                 //res赋值
     
120.                 this.res = res;
     
121.         }
     
122. 
     
123.         //复写run函数
     
124.         public void run()
     
125.         {
     
126. //                while(true)
     
127. //                {
     
128.                         //调用out函数。
     
129.                         res.out();
     
130. //                }
     
131.         }
     
132. }

复制代码

写完这个，听到毕老师说：啊，这个下节课给你们画图演示一下啊！
到了下节课。只看到画面上画好的一张有着勾勾叉叉的图就在那儿放着。。。。

然后毕老师说：
       这个，咳咳。图已经画好了，你们那个、、心里明白怎么画的啊。。我就不说了
。。。。。。然后毕老师的阴笑声：嘿嘿。。那个，看视频的同学可能不知道，来给你们看一下啊、、。。。。。。。。=====================         0.0  0.0   0.0   0.0   0.0

我闭目深呼吸，抬头，食指指向天空，然后厉声大吼道：毕老师你就可劲坑吧！
:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(:'(