学到了线程了，但是老师说有一个，生产者和消费者的例子不怎么好理解。希望谁能帮我写一下。。一定要有详细的注释。我好没学到那里，没注释看不懂！！！

1. import java.util.concurrent.locks.*;
   
2. class ProducerConsumerDemo2
   
3. {
   
4.         public static void main(String[] args)
   
5.         {
   
6.                 Res r=new Res();//创建一个资源对象
   
7.                 Producer pro=new Producer(r);//创建一个生产者
   
8.                 Consumer con=new Consumer(r);//创建一个消费者
   
9. 
   
10.                 Thread t1=new Thread(pro);
    
11.                 Thread t2=new Thread(pro);//创建以上两个线程，即两个生产者线程t1,t2
    
12.                 Thread t3=new Thread(con);
    
13.                 Thread t4=new Thread(con);//创建以上两个线程，即两个消费者线程t3,t4
    
14.                 t1.start();
    
15.                 t2.start();
    
16.                 t3.start();
    
17.                 t4.start();//开启四个线程
    
18.         }
    
19. }
    
20. class Res
    
21. {
    
22.         private String name;
    
23.         private int count=1;
    
24.         private boolean flag=false;
    
25.         private Lock lock=new ReentrantLock();//创建一个锁
    
26.         private Condition condition_pro=lock.newCondition();//该方法是创建一个生产者的Contion对象,目的是执行相应的线程，如只执行生产者的等待和唤醒。
    
27.         private Condition condition_con=lock.newCondition();//该方法是创建一个消费者的Contion对象，目的同上。
    
28.         /*这个方法是生产者生产商品的方法。*/
    
29.         public synchronized void set(String name)throws InterruptedException{
    
30.                 lock.lock();//上锁
    
31.                 try{
    
32.                         while(flag)//若flag为true，表示已经有一个商品了,执行await语句抛出异常。若为false,表示还没有商品，生产者需要生产，则await()句不执行，执行下一句代码。
    
33.                                 condition_pro.await();//那么此时，因为可能还没有被消费者消费，所以为了让生产者不产生新的商品，故让所以生产者线程等待。抛出异常。执行finally语句解锁。
    
34.                         this.name=name+"..."+(count++);
    
35.                         System.out.println(Thread.currentThread().getName()+"生产者..."+this.name);//可以理解为生产商品的语句。
    
36.                         flag=true;//以上语句的意思是生产者已经生产了一个产品，所以用flag=true告诉他们现在有一个商品了。
    
37.                         condition_con.signal();//唤醒所有消费者线程。
    
38.                 }
    
39.                 finally{//加上finally是为了当是否抛出异常时，都能将锁释放，要不然其他线程进不来。
    
40.                         lock.unlock();//解锁
    
41.                 }
    
42.         }
    
43.         /*这个方法是消费者消费商品的方法。上锁解锁的方法如上*/
    
44.         public void out()throws InterruptedException{
    
45.                 lock.lock();
    
46.                 try{
    
47.                         while(!flag)//当flag=false时，!flag=true,表示此时容器里没有商品，消费者不能消费。故用await让所有消费者线程等待。
    
48.                                 condition_con.await();
    
49.                         System.out.println(Thread.currentThread().getName()+"消费者........."+this.name);//可以理解为消费商品的语句。
    
50.                         flag=false;//商品消费完，容器里没有商品了，故把标记变为false.
    
51.                         condition_pro.signalAll();//唤醒线程池里所有的生产者线程。
    
52.                 }
    
53.                 finally{
    
54.                         lock.unlock();
    
55.                 }
    
56.         }
    
57. }
    
58. class Producer implements Runnable//这个是生产者线程，创建商品。
    
59. {
    
60.         private Res r;
    
61.         Producer(Res r){
    
62.                 this.r=r;
    
63.         }
    
64.         public void run(){
    
65.                 while(true){
    
66.                         try{
    
67.                                 r.set("+商品+");
    
68.                         }
    
69.                         catch(InterruptedException e){}
    
70.                 }
    
71.         }
    
72. }
    
73. class Consumer implements Runnable//这个是消费者者线程，消费商品。
    
74. {
    
75.         private Res r;
    
76.         Consumer(Res r){
    
77.                 this.r=r;
    
78.         }
    
79.         public void run(){
    
80.                 while(true){
    
81.                         try{
    
82.                                 r.out();
    
83.                         }
    
84.                         catch(InterruptedException e){}
    
85.                 }
    
86.         }
    
87. }

复制代码

代码可以直接运行的，不知道说的会不会太乱，你能不能理解额~

如果问题已经解决了，那么大家请把帖子的类型改为“已解决”，在自己帖子的左下角点编辑，然后选择帖子的分类进行改正。{:soso_e163:}