多线程多消费的线程处理使用java.concurrent.locks包下的类实现。其代码如下：

1. import java.util.concurrent.locks.*;
   
2. class ThreadLockDemo1
   
3. {
   
4. public static void main(String[] args)
   
5. {
   
6. Resources r=new Resources();
   
7. Input in=new Input(r);
   
8. Output out=new Output(r);
   
9. Thread t1=new Thread(in);
   
10. Thread t2=new Thread(in);
    
11. Thread t3=new Thread(out);
    
12. Thread t4=new Thread(out);
    
13. t1.start();
    
14. t2.start();
    
15. t3.start();
    
16. t4.start();
    
17. }
    
18. }
    
19. class Resources
    
20. {
    
21. String[] res=new String[10];
    
22. int input_index,output_index,count;
    
23. boolean flag=false;
    
24. Lock lock=new ReentrantLock();
    
25. Condition input_Cos=lock.newCondition();
    
26. Condition output_Cos=lock.newCondition();
    
27. public void set(String name)
    
28. {
    
29. lock.lock();
    
30. try{
    
31. 
    
32. while(count==res.length)
    
33. input_Cos.await();
    
34. res[input_index++]=name;
    
35. System.out.println(Thread.currentThread().getName()+"生产"+res[input_index-1]);
    
36. ++count;
    
37. if(input_index==res.length-1)
    
38. input_index=0;
    
39. output_Cos.signal();
    
40. }
    
41. catch(InterruptedException e)
    
42. {
    
43. System.out.println(e);
    
44. }
    
45. finally
    
46. {
    
47. lock.unlock();
    
48. }
    
49. }
    
50. public void get()
    
51. {
    
52. lock.lock();
    
53. try{
    
54. 
    
55. while(count==0)
    
56. output_Cos.await();
    
57. System.out.println(Thread.currentThread().getName()+res[output_index++]);
    
58. --count;
    
59. if(output_index==res.length-1)
    
60. output_index=0;
    
61. input_Cos.signal();
    
62. }
    
63. catch(InterruptedException e)
    
64. {
    
65. System.out.println(e);
    
66. }
    
67. finally
    
68. {
    
69. lock.unlock();
    
70. }
    
71. }
    
72. }
    
73. class Input implements Runnable
    
74. {
    
75. Resources r=null;
    
76. public Input(Resources r)
    
77. {
    
78. this.r=r;
    
79. }
    
80. public void run()
    
81. {
    
82. int i=0;
    
83. while(true)
    
84. {
    
85. r.set("第"+i+"面包");
    
86. i++;
    
87. }
    
88. }
    
89. }
    
90. class Output implements Runnable
    
91. {
    
92. Resources r=null;
    
93. public Output(Resources r)
    
94. {
    
95. this.r=r;
    
96. }
    
97. public void run()
    
98. {
    
99. while(true)
    
100. {
     
101. r.get();
     
102. }
     
103. }
     
104. }
     

复制代码

用这个包的好处在于一个锁里可以有多对的监视器，可以唤星对方的线程。

值得学习ing!