Java多線程應用——生產者消費者

Java多線程應用——生產者消費者：

1. import java.util.Random;
2. /*
3. * @topic:用互斥實現生產者消費者問題
4. */
5. public class Custom{
6. public static void main(String[] args) {
7. FruitBasket fb = new FruitBasket();
8. new Thread(new Farmer("農夫1",fb)).start();
9. new Thread(new Farmer("農夫2",fb)).start();
10. new Thread(new Farmer("農夫3",fb)).start();
11. new Thread(new Child("小孩1",fb)).start();
12. new Thread(new Child("小孩2",fb)).start();
13. new Thread(new Child("小孩3",fb)).start();
14. }
15. }
16. class Fruit{
17. private int id;
18. private static int number = 0;
19. private String variety;
20. private String[] varietys = "蘋果,桃子,梨子,香蕉,西瓜,荔枝,葡萄".split(",");
21. public Fruit(){
22. this.variety = varietys[new Random().nextInt(7)];
23. this.id = ++number;
24. }
25. public int getId(){
26. return this.id;
27. }
28. public String getVariety(){
29. return this.variety;
30. }
31. }
33. class FruitBasket{
34. private Fruit[] fruits = new Fruit[10];//容量為10的水果數組
35. private int index = 0;//下一個將要放入水果的位置
37. public boolean isEmpty(){//判斷水果籃是否為空
38. return index == 0 ?true:false;
39. }
41. public boolean isFull(){//是否為滿
42. return index == fruits.length?true:false;
43. }
45. public synchronized void push(String name , Fruit fruit){//對push方法實行同步
46. while(isFull()){
47. try{
48. this.wait();//��為滿，則不能push，只能等待。
49. }catch(InterruptedException e){
50. e.printStackTrace();
51. }
52. }
53. fruits[index++] = fruit;
54. System.out.println(name + "向水果框中放入編號為" + fruit.getId() + "的"+fruit.getVariety());
55. display();
56. this.notify(); //通知另一線程
57. }
59. public synchronized Fruit pop(String name){
60. while(isEmpty()){
61. try{
62. this.wait();
63. }catch(Exception e){
64. e.printStackTrace();
65. }
66. }
67. Fruit fruit = fruits[--index];
68. System.out.println(name + "從水果框中拿出編號為"+fruit.getId() +"的" + fruit.getVariety());
69. display();
70. this.notify();
71. return fruit;
72. }
74. public void display(){
75. for(int i = 0 ; i < index ; i++){
76. System.out.printf(fruits[i].getId()+fruits[i].getVariety() + " |");
77. }
78. for (int i = index; i < fruits.length; i++) {
79. System.out.printf( "[" + (i + 1) + "]|");
80. }
81. System.out.println("\n");
82. }
83. }
85. class Farmer implements Runnable{
86. private String name ;
87. private FruitBasket fruitBasket;
88. public void run(){//不斷往籃子中放
89. while(true){
90. fruitBasket.push(name,new Fruit());
91. try{
92. Thread.sleep(new Random().nextInt(2000));
93. }catch(Exception e){
94. e.printStackTrace();
95. }
96. }
97. }
98. Farmer(String name, FruitBasket fruitBasket) {
99. this.name = name;
100. this.fruitBasket = fruitBasket;
101. }
103. }
105. class Child implements Runnable{
106. private String name;
107. private FruitBasket fruitBasket;
108. public void run(){//不斷往籃子中取
109. while(true){
110. fruitBasket.pop(this.name);
111. try{
112. Thread.sleep(new Random().nextInt(5000));
113. }catch(Exception e){
114. e.printStackTrace();
115. }
116. }
117. }
118. Child(String name, FruitBasket fruitBasket) {
119. this.name = name;
120. this.fruitBasket = fruitBasket;
121. }
122. }