代码如下：

1. package thread;
   
2. import java.util.*;
   
3. import java.util.concurrent.* ;
   
4. 
   
5. 
   
6. 
   
7. //resource
   
8. class Resource{
   
9.        
   
10.                  private String name;
    
11.                  private int id;
    
12.                  private boolean falg;
    
13.                  private Lock lock = new ReentrantLock();
    
14.                  private  Condition con_pro = lock.newCondition();
    
15.                  private Condition con_con = lock.newCondition();
    
16.                 
    
17.         public void setName(String name){
    
18.                
    
19.                
    
20.                 this.name = name;       
    
21.                
    
22.         }
    
23.         public void setId(int id){
    
24.                
    
25.                 this.id = id ;       
    
26.                
    
27.         }
    
28.         public void setInfo(String name)throws InterruptedException{
    
29.                
    
30.                 lock.lock();try{
    
31.     while(falg){
    
32.                                
    
33.                                         con_pro.await();                               
    
34.                                 }
    
35.                                
    
36.                
    
37.                
    
38.                 this.name = name;
    
39.                 this.id = id;
    
40.                 falg = true;
    
41.                 con_con.signal();       
    
42.                 }       
    
43.                         finally{
    
44.                                        
    
45.                                         lock.unLock();       
    
46.                                 }
    
47.         }
    
48.        
    
49.         public void getInof(){
    
50.                
    
51.                 lock.lock();
    
52.                
    
53.                 while(!falg){
    
54.                        
    
55.                         try{
    
56.                                
    
57.                                         con_con.await();
    
58.                         }
    
59.                         finally{
    
60.                                
    
61.                                 lock.unLock();
    
62.                                                        
    
63.                         }
    
64.                                
    
65.                 }
    
66.                 System.out.println(Thread.currentThread().getName()+"Name:"+name+"+Id:"+id);       
    
67.                 id++;
    
68.         }
    
69. }
    
70. 
    
71. 
    
72. class Producer implements Runnable{
    
73. 
    
74.         private Resource res;
    
75.        
    
76.         Producer(Resource res){
    
77.                
    
78.                 this.res = res;       
    
79.         }       
    
80.        
    
81.         public void run(){
    
82.                         while(true){
    
83.                        
    
84.                                 try{
    
85.                                        
    
86.                                                 res.setInfo("产品");       
    
87.                                 }       
    
88.                                 catch(InterruptedException e){
    
89.                                        
    
90.                                         e.printlStackTrace();
    
91.                                                
    
92.                                 }                       
    
93.                                
    
94.                         }
    
95.         }
    
96. }
    
97. 
    
98. class Concumter implements Runnable{
    
99.        
    
100.         private Resource res;
     
101.        
     
102.         Concumter(Resource res){
     
103.        
     
104.                 this.res = res;       
     
105.         }       
     
106.        
     
107.         public void run(){
     
108.                
     
109.                 while(true){
     
110.                        
     
111.                         res.getInfo();       
     
112.                 }
     
113.                        
     
114.         }
     
115. }
     
116. 
     
117. public class ProducerLock{
     
118.        
     
119.         public static void main(String [] args){
     
120.                
     
121.                 Resource res = new Resource();
     
122.                
     
123.                 new Thread(new Producer(res)).start();
     
124.                 new Thread(new Producer(res)).start();
     
125.                 new Thread(new Consumer(res)).start();
     
126.                 new Thread(new Consumer(res)).start();       
     
127.         }       
     
128. }

复制代码

此代码还有一些别的问题，我就想知道为什么编译会提示找不到Condition类

Condition是java.util.concurrent.locks.*;

这个问题多注意吧.包下的子包是不会在用*导入时导入的.
有子包的话,要明确到子包哦.

有点内部类访问的那种味道...自己品品~

高亮亮 发表于 2014-1-8 16:04
Condition是java.util.concurrent.locks.*;

这个问题多注意吧.包下的子包是不会在用*导入时导入的.

如果使用import java.util.*;导入，我试过也不行呀，

无道 发表于 2014-1-11 22:05
如果使用import java.util.*;导入，我试过也不行呀，

concurrent.被你吃了...

是不是我的虚拟机缺少一个jar包呀!希望能在你们的机子上运行一下，证实一下，谢谢。

刚提交的入学申请,看谈出来一个新消息,以为审核了,害我白激动一场啊
请你看信息,看仔细.到以后码代码不仔细,会返工很多东西滴!~

import java.util.*;
import java.util.concurrent.* ;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;



//resource
class Resource{
        
                 private String name;
                 private int id;
                 private boolean falg;
                 private Lock lock = new ReentrantLock();
                 private  Condition con_pro = lock.newCondition();
                 private Condition con_con = lock.newCondition();
                 
        public void setName(String name){
               
               
                this.name = name;        
               
        }
        public void setId(int id){
               
                this.id = id ;        
               
        }
        public void setInfo(String name)throws InterruptedException{
               
                lock.lock();try{
    while(falg){
                                
                                        con_pro.await();                                
                                }
                                
               
               
                this.name = name;
                this.id = id;
                falg = true;
                con_con.signal();        
                }        
                        finally{
                                       
                                        lock.unlock();        
                                }
        }
        
        public void getInof() throws InterruptedException {
               
                lock.lock();
               
                while(!falg){
                        
                        try{
                                
                                        con_con.await();
                        }
                        finally{
                                
                                lock.unlock();
                                                        
                        }
                                
                }
                System.out.println(Thread.currentThread().getName()+"Name:"+name+"+Id:"+id);        
                id++;
        }
}


class Producer implements Runnable{

        private Resource res;
        
        Producer(Resource res){
               
                this.res = res;        
        }        
        
        public void run(){
                        while(true){
                        
                                try{
                                       
                                                res.setInfo("产品");        
                                }        
                                catch(InterruptedException e){
                                       
                                        e.printStackTrace();
                                                
                                }                        
                                
                        }
        }
}

class Concumter implements Runnable{
        
        private Resource res;
        
        Concumter(Resource res){
        
                this.res = res;        
        }        
        
        public void run(){
               
                while(true){
                        
                        try {
                                                        res.getInof();
                                                } catch (InterruptedException e) {
                                                        // TODO 自动生成的 catch 块
                                                        e.printStackTrace();
                                                }        
                }
                        
        }
}

public class ProducerLock{
        
        public static void main(String [] args){
               
                Resource res = new Resource();
               
                new Thread(new Producer(res)).start();
                new Thread(new Producer(res)).start();
                new Thread(new Concumter(res)).start();
                new Thread(new Concumter(res)).start();        
        }        
}
这是我改过的 现在没问题了   导入了哪些包你自己看 还有就是你的代码中有些大小写错误改改