1. public class ProducerConsumerTest {
   
2. 
   
3.         public static void main(String[] args) {
   
4.                 Resource res = new Resource();
   
5.                 Producer p = new Producer(res);
   
6.                 Consumer c = new Consumer(res);
   
7.                
   
8.                 Thread t1 = new Thread(p);
   
9.                 Thread t2 = new Thread(c);
   
10.                 Thread t3 = new Thread(p);
    
11.                 Thread t4 = new Thread(c);
    
12.                 t1.start();
    
13.                 t2.start();
    
14.                 t3.start();
    
15.                 t4.start();
    
16. 
    
17.         }
    
18. 
    
19. }
    
20. 
    
21. class Resource{
    
22.         private String name;
    
23.         private int count = 1;
    
24.         private boolean flag = false;
    
25.         public synchronized void set(String name){
    
26.                 while(flag){
    
27.                                 try{this.wait();}catch(Exception e){}
    
28.                         this.name = name+"..."+count++;
    
29.                         System.out.println(Thread.currentThread().getName()+"---生产者---"+this.name);
    
30.                         flag = true;
    
31.                         this.notifyAll();
    
32.                 }
    
33.         }
    
34.         public synchronized void out(){
    
35.                 while(!flag){
    
36.                                 try{this.wait();}catch(Exception e){}
    
37.                         System.out.println(Thread.currentThread().getName()+"-----消费者-----"+this.name);
    
38.                         flag = false;
    
39.                         this.notifyAll();
    
40.                 }
    
41.         }
    
42. }
    
43. class Producer implements Runnable{
    
44.         private Resource res;
    
45.         Producer(Resource res){
    
46.                 this.res = res;
    
47.         }
    
48.         public void run() {
    
49.                 while(true){
    
50.                         res.set("zhangsan");
    
51.                 }
    
52.         }
    
53.        
    
54. }
    
55. class Consumer implements Runnable{
    
56. 
    
57.         private Resource res;
    
58.         Consumer(Resource res){
    
59.                 this.res = res;
    
60.         }
    
61.         public void run() {
    
62.                 while(true){
    
63.                         res.out();
    
64.                 }
    
65.         }
    
66.        
    
67. }

复制代码

看毕姥爷多线程视频写的生产者消费者，运行没反应，麻烦大家来瞅瞅

沙发 我还没看到哪里了