1. 
   
2. import java.util.Random;
   
3. import java.util.concurrent.CountDownLatch;
   
4. import java.util.concurrent.locks.Condition;
   
5. import java.util.concurrent.locks.Lock;
   
6. import java.util.concurrent.locks.ReentrantLock;
   
7. 
   
8. public class ConditionDemo {
   
9.         private final Lock lock = new ReentrantLock();
   
10.         private final Condition isFull = lock.newCondition();
    
11.         private final Condition isEmtry = lock.newCondition();
    
12.         private String[] data = new String[10];
    
13.         private int len, getStr,putStr;
    
14.         private StringBuilder buff = new StringBuilder();
    
15.         public void putData(){
    
16.                 lock.lock();
    
17.                 System.out.println("正在填充数据...");
    
18.                 try{
    
19.                         while(len==data.length){
    
20.                                 System.out.println(Thread.currentThread().getName()+" 填充完毕...");  // 这里无法打印
    
21.                                 putStr=buff.length();
    
22.                                 try{
    
23.                                         isFull.await();
    
24.                                 }catch(InterruptedException e){
    
25.                                         System.err.println(e.toString());
    
26.                                 }
    
27.                         }
    
28.                         while(putStr<=data.length){
    
29.                         if(putStr==data.length){
    
30.                                 putStr = 0;
    
31.                                 break;
    
32.                         }
    
33.                         data[putStr] = String.valueOf(new Random().nextInt(100));
    
34.                         System.out.println("data["+putStr+"]="+data[putStr]);
    
35.                         ++putStr;
    
36.                         ++len;
    
37.                         }
    
38.                         isEmtry.signal();
    
39.                 }finally{
    
40.                         lock.unlock();
    
41.                 }
    
42.                
    
43.         }
    
44.         public void getData(){
    
45.                 lock.lock();
    
46.                 System.out.println("正在截获信息...");  // 运行到这里，卡住了
    
47.                 try{
    
48.                         while(len==0){                       
    
49.                                 System.out.println(Thread.currentThread().getName()+"截获数据完毕...");
    
50.                                 System.out.println(buff.toString());
    
51.                                 try {
    
52.                                         isEmtry.await();
    
53.                                 } catch (InterruptedException e) {
    
54.                                         e.printStackTrace();
    
55.                                 }
    
56.                         }
    
57.                  while(getStr<=data.length){
    
58.                  if(getStr==data.length){
    
59.                          getStr = 0;
    
60.                          break;
    
61.                  }
    
62.                  String info = data[getStr];
    
63.                  buff.append(info+",");
    
64.              ++getStr;
    
65.                  --len;
    
66.                  }
    
67.                  isFull.signal();
    
68.                 }finally{
    
69.                         lock.unlock();
    
70.                 }
    
71.         }
    
72.         public static void main(String[] args) {
    
73.            final ConditionDemo condition = new ConditionDemo();
    
74.            final CountDownLatch latch = new CountDownLatch(1);
    
75.          
    
76.            new Thread(new Runnable(){
    
77.                   
    
78.                   @Override
    
79.                   public void run(){
    
80.                         condition.putData();
    
81.                         latch.countDown();
    
82.                   }
    
83.            }).start();
    
84.           
    
85.            try {
    
86.                                  latch.await();
    
87.                           } catch (InterruptedException e) {               
    
88.                                         e.printStackTrace();
    
89.                         }
    
90.           
    
91.               condition.getData();
    
92.         }
    
93. 
    
94. }
    

复制代码

我是新手。。但是我测试了一下

1. public void getData(){
   
2. 
   
3.                 lock.lock();
   
4. 
   
5.                 System.out.println("正在截获信息...");  // 运行到这里，卡住了
   
6. 
   
7.                 try{
   
8. 
   
9.                         while(len==0){                        //因为没输出Thread.currentThread().getName()+"截获数据完毕..."，所以len应该是！=0吧，你改成while(len!=0)试试
   
10.                                 System.out.println(Thread.currentThread().getName()+"截获数据完毕...");
    
11. 
    
12.                                 System.out.println(buff.toString());
    
13. 
    
14.                                 try {
    
15. 
    
16.                                         isEmtry.await();
    
17. 
    
18.                                 } catch (InterruptedException e) {
    
19. 
    
20.                                         e.printStackTrace();
    
21. 
    
22.                                 }
    
23. 
    
24.                         }
    
25. 
    

复制代码

张子凯 发表于 2013-3-8 10:57
我是新手。。但是我测试了一下

另外监视器获取一个数据，长度减少一个，当截取完数据，长度应当为0，这里不用修改

赵文 发表于 2013-3-8 11:01
另外监视器获取一个数据，长度减少一个，当截取完数据，长度应当为0，这里不用修改 ...

我新手。。毕老师的视频才学到第8天，来凑个热闹，而且改了确实不对。。。