1. import java.util.concurrent.locks.*;
   
2. class Res
   
3. {
   
4. private String name;
   
5. private int nex = 1;
   
6. private boolean fiag = false;
   
7. 
   
8. private Lock lock = new ReentrantLock();
   
9. 
   
10. private Condition condition_pro = lock.newCondition();
    
11. private Condition condition_con = lock.newCondition();
    
12. 
    
13. 
    
14. public void set (String name)throws InterruptedException
    
15. {
    
16. lock.lock(); //加锁
    
17. try
    
18. {
    
19. while (fiag)
    
20. condition_pro.await();//set 的等待
    
21. this.name = name+" "+nex++;
    
22. 
    
23. System.out.println(Thread.currentThread().getName()+"...生产者.."+this.name);
    
24. fiag = true;
    
25. condition_con.signal(); //唤醒对方的等待
    
26. }
    
27. finally
    
28. {
    
29. lock.unlock(); //释放锁。 这个动作一定执行
    
30. }
    
31. }
    
32. 
    
33. public void out ()throws InterruptedException
    
34. {
    
35. lock.lock(); //加锁
    
36. try
    
37. {
    
38. while(!fiag);
    
39. condition_con.await();
    
40. System.out.println(Thread.currentThread().getName()+"... 消费者 .."+this.name);
    
41. fiag = false;
    
42. condition_pro.signal();
    
43. }
    
44. finally
    
45. {
    
46. lock.unlock();//释放锁。 这个动作一定执行
    
47. }
    
48. 
    
49. 
    
50. 
    
51. }
    
52. }
    
53. 
    
54. class Producer implements Runnable
    
55. {
    
56. private Res r;
    
57. Producer (Res r)
    
58. {
    
59. this.r = r;
    
60. }
    
61. public void run()
    
62. {
    
63. while (true)
    
64. {
    
65. try
    
66. {
    
67. r.set("商品");
    
68. }
    
69. catch (InterruptedException e)
    
70. {
    
71. }
    
72. 
    
73. }
    
74. }
    
75. }
    
76. 
    
77. class Demo implements Runnable
    
78. {
    
79. private Res r;
    
80. Demo(Res r)
    
81. {
    
82. this.r = r;
    
83. }
    
84. public void run()
    
85. {
    
86. while (true)
    
87. {
    
88. try
    
89. {
    
90. r.out();
    
91. }
    
92. catch (InterruptedException e)
    
93. {
    
94. }
    
95. 
    
96. }
    
97. }
    
98. 
    
99. }
    
100. 
     
101. class ProducerDemo4
     
102. {
     
103. public static void main (String [] asge)
     
104. {
     
105. Res r = new Res();
     
106. 
     
107. Producer pro = new Producer(r);
     
108. Demo de = new Demo(r);
     
109. 
     
110. Thread a1 = new Thread(pro);
     
111. Thread a2 = new Thread(pro);
     
112. Thread a3 = new Thread(de);
     
113. Thread a4 = new Thread(de);
     
114. 
     
115. a1.start();
     
116. a2.start();
     
117. a3.start();
     
118. a4.start();
     
119. }
     
120. }
     
121. 
     

复制代码

我要崩溃了   求高人能看看哪里错了。
运行结果是
Thread-0...生产者.. 商品 1
之后就卡那里了。。

class Res
{
private String name;
private int nex = 1;
private boolean fiag = false;

private Lock lock = new ReentrantLock();

private Condition condition_pro = lock.newCondition();
private Condition condition_con = lock.newCondition();


public void set (String name)throws InterruptedException
{
lock.lock(); //加锁
try
{
while (fiag)
        condition_pro.await();//set 的等待
this.name = name+" "+nex++;

System.out.println(Thread.currentThread().getName()+"...生产者.."+this.name);
fiag = true;
condition_con.signal(); //唤醒对方的等待
}
finally
{
lock.unlock(); //释放锁。 这个动作一定执行
}
}

public void out ()throws InterruptedException
{
lock.lock(); //加锁
try
{
while(!fiag);//问题出在这里，你的while循环后面跟了一个分号。所以默认方法体为空，线程一直在做死循环。分号去掉即可
        condition_con.await();
System.out.println(Thread.currentThread().getName()+"... 消费者 .."+this.name);
fiag = false;
condition_pro.signal();
}
finally
{
lock.unlock();//释放锁。 这个动作一定执行
}



}
}

{:soso_e136:}   我晕    {:soso_e179:} 万分感谢