1. 想搞个停止生产，和消费的方法，      不知道从那下手，百度也没出来，会的提示一下。

复制代码

1. package prouderComsumer;
   
2. 
   
3. import java.util.concurrent.locks.Condition;
   
4. import java.util.concurrent.locks.Lock;
   
5. import java.util.concurrent.locks.ReentrantLock;
   
6. 
   
7. //多线程间通信问题               <生产烤鸭问题>
   
8. /*resoures  producer consumer  和主函数创建线程4个类。resoures定义生产和消费的方法，producer和consumer定义接受resoures的构造函数
   
9. * ，并实现多线程。*/
   
10. public class ProuderComsumerDemo {
    
11.                         public static void main(String[] args) {
    
12.                                 resoures r = new resoures();
    
13.                                 producer pro = new producer(r);
    
14.                                 consumer con =new consumer(r);
    
15.                                 Thread t1 = new Thread(pro);
    
16.                                 Thread t2 = new Thread(pro);
    
17.                                 Thread t3 = new Thread(con);
    
18.                                 Thread t4 = new Thread(con);
    
19.                                 t1.start();
    
20.                                 t2.start();
    
21.                                 t3.start();
    
22.                             t4.start();
    
23. }
    
24. }
    
25. //资源
    
26.   class resoures {
    
27.           //定义变量：生产什么。生产多少了，生产与消费之间的切换变量
    
28.           private String name;
    
29.           private  int count=0;
    
30.           private  boolean falg =false;
    
31.           //生产方法
    
32.        
    
33.           public synchronized void set(String name){
    
34.                   // 什么时候生产
    
35.                
    
36.                   while(falg)
    
37.                         try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}//睡觉
    
38.                    //生产      
    
39.                      count++;
    
40.                   if(count==1000){
    
41.                          
    
42.                   }
    
43.                   this.name = name+count;
    
44.                   System.out.println(Thread.currentThread().getName()+"生 产 了"+this.name);
    
45.                   //生产完了要告诉消费者
    
46.                   falg=true;
    
47.                   notifyAll();
    
48.                  
    
49.          
    
50.           }
    
51.          //消费方法
    
52.           public synchronized void out(){
    
53.                       while(!falg)
    
54.                                 try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}
    
55.                      
    
56.                     System.out.println(Thread.currentThread().getName()+"消 费 了"+this.name);
    
57.                     falg=false;
    
58.                           notifyAll();
    
59.           }
    
60.   }
    
61. //生产者
    
62. class producer implements Runnable{
    
63.          private resoures r;
    
64.          
    
65.         public producer(resoures r) {
    
66.                         super();
    
67.                         this.r = r;
    
68.                 }
    
69. 
    
70.         @Override
    
71.         public void run() {
    
72.                    while(true){
    
73.                            r.set("烤鸭");
    
74.                           
    
75.                    }
    
76.                
    
77.         }
    
78.        
    
79. }
    
80. //消费者
    
81. class consumer implements Runnable{
    
82.     private resoures r;
    
83.    
    
84. public consumer(resoures r) {
    
85.                 super();
    
86.                 this.r = r;
    
87.         }
    
88. 
    
89. @Override
    
90. public void run() {
    
91.            while(true){
    
92.                    r.out();
    
93.                   
    
94.                           
    
95.                   
    
96.            }
    
97.        
    
98. }
    
99. 
    
100. }

复制代码

上面的问题怎么没代码  ，郁闷。。。。。