1. /*
   
2. * 为什么运行一次后就卡死。
   
3. */
   
4. 
   
5. package cn.copy;
   
6. 
   
7. import java.util.concurrent.locks.Condition;
   
8. import java.util.concurrent.locks.ReentrantLock;
   
9. 
   
10. public class DateBaseDemo {
    
11. 
    
12.         public static void main(String[] args) {
    
13.                 DateBase db = new DateBase();
    
14.                 new DBA(db).start();
    
15.                 new Developer(db).start();
    
16.         }
    
17. 
    
18. }
    
19. 
    
20. class DateBase {
    
21.         String name;
    
22.         String sex;
    
23.         boolean Update;
    
24.         ReentrantLock lock = new ReentrantLock();
    
25.         Condition c1 = lock.newCondition();
    
26.         Condition c2 = lock.newCondition();
    
27. }
    
28. 
    
29. class DBA extends Thread {
    
30.         private DateBase db;
    
31.         private int times;
    
32. 
    
33.         public DBA(DateBase db) {
    
34.                 this.db = db;
    
35.         }
    
36. 
    
37.         public void run() {
    
38.                 while (true) {
    
39.                         db.lock.lock();
    
40.                         if (db.Update == true)
    
41.                                 try {
    
42.                                         db.c1.await();
    
43.                                 } catch (InterruptedException e) {
    
44.                                         // TODO Auto-generated catch block
    
45.                                         e.printStackTrace();
    
46.                                 }
    
47.                         if (times++ % 2 == 0) {
    
48.                                 db.name = "秦岩";
    
49.                                 db.sex = "男";
    
50.                         } else {
    
51.                                 db.name = "晁喆";
    
52.                                 db.sex = "女";
    
53.                         }
    
54.                         db.Update = true;
    
55.                         db.c2.signal();
    
56.                         db.lock.unlock();
    
57.                 }
    
58.         }
    
59. }
    
60. 
    
61. class Developer extends Thread {
    
62.         private DateBase db;
    
63. 
    
64.         public Developer(DateBase db) {
    
65.                 this.db = db;
    
66.         }
    
67. 
    
68.         public void run() {
    
69.                 db.lock.lock();
    
70.                 if (db.Update == false)
    
71.                         try {
    
72.                                 db.c2.await();
    
73.                         } catch (InterruptedException e) {
    
74.                                 // TODO Auto-generated catch block
    
75.                                 e.printStackTrace();
    
76.                         }
    
77.                 System.out.println(db.name + ", " + db.sex);
    
78.                 db.Update = false;
    
79.                 db.c1.signal();
    
80.                 db.lock.unlock();
    
81.         }
    
82. }
    

复制代码

哪里错了吗？ 我实在是找不到啊~~~  帮帮忙~~

改为实现Runnable接口。

申振华 发表于 2012-4-8 23:44
改为实现Runnable接口。

为什么？

class Developer extends Thread {
        private DateBase db;

        public Developer(DateBase db) {
                this.db = db;
        }

        public void run() {这里少了一个while循环，，
while(true){
                db.lock.lock();
                if (db.Update == false)
                        try {
                                db.c2.await();
                        } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                System.out.println(db.name + ", " + db.sex);
                db.Update = false;
                db.c1.signal();
          }      db.lock.unlock();
        }
}

很好！！（此回复虽然仅有两个字，却深刻地表达了回复人的深深情感，可谓言简意赅，一字千金，字字扣人心弦！再加上以感叹号收尾，点睛之笔，妙笔生花，意境之深远，令人回味无穷!)