1. /*
   
2. 多生产者和多消费者   等待唤醒机制
   
3. */
   
4. class ThreadDemo_Producer_Consumer2
   
5. {
   
6.         public static void main(String[] args)
   
7.         {
   
8.                 Resource r=new Resource();
   
9.                 Producer pro=new Producer(r);
   
10.                 Consumer con=new Consumer(r);
    
11.                 Thread t1=new Thread(pro);
    
12.                 Thread t2=new Thread(pro);
    
13.                 Thread t3=new Thread(con);
    
14.                 Thread t4=new Thread(con);
    
15.                 t1.start();
    
16.                 t2.start();
    
17.                 t3.start();
    
18.                 t4.start();
    
19.         }
    
20. }
    
21. 
    
22. class Resource
    
23. {
    
24.         //定义一个商品的名字
    
25.         private String name;
    
26.         //定义一个商品的编号
    
27.         private int count=1;
    
28.         //定义标记
    
29.         boolean flag=false;
    
30.         public synchronized void set(String name)
    
31.         {
    
32.                 while(flag)
    
33.                         try
    
34.                         {
    
35.                                 wait();
    
36.                         }
    
37.                         catch (InterruptedException e)
    
38.                         {
    
39.                         }
    
40.                 this.name=name+"---"+count;
    
41.                 count++;
    
42.                 System.out.println(Thread.currentThread().getName()+"...生产了,"+this.name);
    
43.                 //将标记改为true
    
44.                 flag=true;
    
45.                 notifyAll();
    
46.         }
    
47.         public synchronized void get()
    
48.         {
    
49.                 while(!flag)
    
50.                         try
    
51.                         {
    
52.                                 wait();
    
53.                         }
    
54.                         catch (InterruptedException e)
    
55.                         {
    
56.                         }
    
57.                 System.out.println(Thread.currentThread().getName()+"...消费了.."+this.name);
    
58.                 flag=!flag;
    
59.                 notifyAll();
    
60.         }
    
61. }
    
62. //定义生产者的任务
    
63. class Producer implements Runnable
    
64. {
    
65.         private Resource r;
    
66.         Producer(Resource r)
    
67.         {
    
68.                 this.r=r;
    
69.         }
    
70.         public void run()
    
71.         {
    
72.                 while(true)
    
73.                 {
    
74.                         r.set("蛋糕");
    
75.                 }
    
76.         }
    
77. }
    
78. //定义消费者的任务
    
79. class Consumer implements Runnable
    
80. {
    
81.         private Resource r;
    
82.         Consumer(Resource r)
    
83.         {
    
84.                 this.r=r;
    
85.         }
    
86.         public void run()
    
87.         {
    
88.                 while(true)
    
89.                 {
    
90.                         r.get();
    
91.                 }
    
92.         }
    
93. }

复制代码

1. /*
   
2. 多生产者和多消费者   等待唤醒机制
   
3. */
   
4. class ThreadDemo_Producer_Consumer2
   
5. {
   
6.         public static void main(String[] args)
   
7.         {
   
8.                 Resource r=new Resource();
   
9.                 Producer pro=new Producer(r);
   
10.                 Consumer con=new Consumer(r);
    
11.                 Thread t1=new Thread(pro);
    
12.                 Thread t2=new Thread(pro);
    
13.                 Thread t3=new Thread(con);
    
14.                 Thread t4=new Thread(con);
    
15.                 t1.start();
    
16.                 t2.start();
    
17.                 t3.start();
    
18.                 t4.start();
    
19.         }
    
20. }
    
21. 
    
22. class Resource
    
23. {
    
24.         //定义一个商品的名字
    
25.         private String name;
    
26.         //定义一个商品的编号
    
27.         private int count=1;
    
28.         //定义标记
    
29.         boolean flag=false;
    
30.         public synchronized void set(String name)
    
31.         {
    
32.                 while(flag)
    
33.                         try
    
34.                         {
    
35.                                 wait();
    
36.                         }
    
37.                         catch (InterruptedException e)
    
38.                         {
    
39.                         }
    
40.                 this.name=name+"---"+count;
    
41.                 count++;
    
42.                 System.out.println(Thread.currentThread().getName()+"...生产了,"+this.name);
    
43.                 //将标记改为true
    
44.                 flag=true;
    
45.                 notifyAll();
    
46.         }
    
47.         public synchronized void get()
    
48.         {
    
49.                 while(!flag)
    
50.                         try
    
51.                         {
    
52.                                 wait();
    
53.                         }
    
54.                         catch (InterruptedException e)
    
55.                         {
    
56.                         }
    
57.                 System.out.println(Thread.currentThread().getName()+"...消费了.."+this.name);
    
58.                 flag=!flag;
    
59.                 notifyAll();
    
60.         }
    
61. }
    
62. //定义生产者的任务
    
63. class Producer implements Runnable
    
64. {
    
65.         private Resource r;
    
66.         Producer(Resource r)
    
67.         {
    
68.                 this.r=r;
    
69.         }
    
70.         public void run()
    
71.         {
    
72.                 while(true)
    
73.                 {
    
74.                         r.set("蛋糕");
    
75.                 }
    
76.         }
    
77. }
    
78. //定义消费者的任务
    
79. class Consumer implements Runnable
    
80. {
    
81.         private Resource r;
    
82.         Consumer(Resource r)
    
83.         {
    
84.                 this.r=r;
    
85.         }
    
86.         public void run()
    
87.         {
    
88.                 while(true)
    
89.                 {
    
90.                         r.get();
    
91.                 }
    
92.         }
    
93. }

复制代码