java多线程总结六：经典生产者消费者问题实现

这是个线程同步的经典例子，源代码如下：

[java] view plaincopy

1. <span style="font-size:16px;">package demo.thread;
2. /**
3. *经典生产者与消费者问题：生产者不断的往仓库中存放产品，消费者从仓库中消费产品。
4. *其中生产者和消费者都可以有若干个。仓库容量有限，库满时不能存放，库空时不能取产品
5. */
6. public class ProducersAndConsumers {
7. public static void main(String[] args) {
8. Storage storage = new Storage();
9. Thread consumer = new Thread(new Consumer(storage));
10. consumer.setName("消费者");
11. Thread producer = new Thread(new Producer(storage));
12. producer.setName("生产者");
13. consumer.start();
14. producer.start();
15. }
16. }
17. /**
18. * 消费者
19. */
20. class Consumer implements Runnable {
21. private Storage storage;
22. public Consumer(Storage storage) {
23. this.storage = storage;
24. }
25. @Override
26. public void run() {
27. storage.pop();
28. }
29. }
30. /**
31. * 生产者
32. */
33. class Producer implements Runnable {
34. private Storage storage;
35. public Producer(Storage storage) {
36. this.storage = storage;
37. }
38. @Override
39. public void run() {
40. Product product = new Product("090505105", "电话");
41. storage.push(product);
42. }
43. }
44. /**
45. * 产品类
46. */
47. class Product {
48. private String id;// 产品id
49. private String name;// 产品名称
50. public Product(String id, String name) {
51. this.id = id;
52. this.name = name;
53. }
54. @Override
55. public String toString() {
56. return "(产品ID：" + id + " 产品名称：" + name + ")";
57. }
58. public String getId() {
59. return id;
60. }
61. public void setId(String id) {
62. this.id = id;
63. }
64. public String getName() {
65. return name;
66. }
67. public void setName(String name) {
68. this.name = name;
69. }
70. }
71. /**
72. *仓库
73. */
74. class Storage {
75. // 仓库容量为10
76. private Product[] products = new Product[10];
77. private int top = 0;
78. // 生产者往仓库中放入产品
79. public synchronized void push(Product product) {
80. while (top == products.length) {
81. try {
82. wait();//仓库已满，等待
83. } catch (InterruptedException e) {
84. // TODO Auto-generated catch block
85. e.printStackTrace();
86. }
87. }
88. //把产品放入仓库
89. products[top++] = product;
90. System.out.println(Thread.currentThread().getName() + " 生产了产品"
91. + product);
92. notifyAll();//唤醒等待线程
93. }
94. // 消费者从仓库中取出产品
95. public synchronized Product pop() {
96. while (top == 0) {
97. try {
98. wait();//仓库空，等待
99. } catch (InterruptedException e) {
100. // TODO Auto-generated catch block
101. e.printStackTrace();
102. }
103. }
104. //从仓库中取产品
105. --top;
106. Product p = new Product(products[top].getId(), products[top].getName());
107. products[top] = null;
108. System.out.println(Thread.currentThread().getName() + " 消费了产品" + p);
109. notifyAll();//唤醒等待线程
110. return p;
111. }
112. }
113. </span>

运行结果：

生产者 生产了产品(产品ID：090505105 产品名称：电话)
消费者 消费了产品(产品ID：090505105 产品名称：电话)