生产者与消费者以及多个容器的多线程问题(经典 集合了老师，同学以及自己的想法)

1 package day2016_10_25_Thread;
2
3 import java.util.LinkedList;
4 import java.util.Random;
5
6 public class Productor {
7     public static void main(String[] args) throws InterruptedException {
8
9         //多个容器
10         Box box = new Box();
11         Box box2 = new Box();
12
13         //解决生产者，消费者，容器共用一个对象锁的问题
14         Object obj=new Object();
15         Producter p = new Producter(box, box2,obj);
16         Customer c = new Customer(box, box2,obj);
17
18         Thread tp = new Thread(p, "productor");
19         Thread tc = new Thread(c, "consumer");
20
21         tp.start();
22         tc.start();
23
24         Thread.sleep(3000);
25         System.out.println(box.size() + "--------------------" + box2.size());
26     }
27 }
28
29 class Producter implements Runnable {
30     Object obj;
31     Box box1;
32     Box box2;
33
34     Producter(Box box1, Box box2,Object obj) {
35         this.box1 = box1;
36         this.box2 = box2;
37         this.obj=obj;
38     }
39
40     @Override
41     public void run() {
42
43         System.out.println(Thread.currentThread().getName());
44
45         for (int i = 0; i < 30; i++) {
46             synchronized (obj) {
47                 obj.notify();
48                 if(i==49){
49                     System.out.println("生产者30次循环结束！");
50                 }
51                 if (box1.size() >= 10 && box2.size() >= 10) {
52                     try {
53                         obj.wait(); // 本线程等待
54                     } catch (InterruptedException e) {
55                         e.printStackTrace();
56                     }
57                 } else if (box1.size() >= 10 && box2.size() < 10) {
58                     box2.push(new Bread("bread-" + i));
59                     System.out.println(Thread.currentThread().getName()
60                             + "-> box2 : " + box2.size());
61                 } else if (box1.size() < 10 && box2.size() >= 10) {
62                     box1.push(new Bread("bread-" + i));
63                     System.out.println(Thread.currentThread().getName()
64                             + "-> box1 : " + box1.size());
65                 } else {
66                     Random ran = new Random();
67                     int num = ran.nextInt(2);
68                     if (num == 0) {
69                         box1.push(new Bread("bread-" + i));
70                         System.out.println(Thread.currentThread().getName()
71                                 + "-> box1 : " + box1.size());
72                     } else {
73                         box2.push(new Bread("bread-" + i));
74                         System.out.println(Thread.currentThread().getName()
75                                 + "-> box2 : " + box2.size());
76                     }
77                 }
78             }
79         }
80
81     }
82 }
83
84 class Customer implements Runnable {
85     Object obj;
86     Box box1;
87     Box box2;
88
89     Customer(Box box1, Box box2,Object obj) {
90         this.box1 = box1;
91         this.box2 = box2;
92         this.obj=obj;
93     }
94
95     @Override
96     public void run() {
97
98         System.out.println(Thread.currentThread().getName());
99
100         for (int i = 0; i < 30; i++) {
101             synchronized (obj) {
102                 obj.notify();
103                 if(i==49){
104                     System.out.println("消费者30次循环结束！");
105                 }
106                 if (box1.size() <= 3 && box2.size() <= 3) {
107                     try {
108                         obj.wait();
109                     } catch (InterruptedException e) {
110                         e.printStackTrace();
111                     }
112                 } else if (box1.size() <= 3 && box2.size() > 3) {
113                     Bread b2 = box2.pop();
114                     System.out.println(Thread.currentThread().getName()
115                             + "-> box2 : " + b2);
116                 } else if (box1.size() > 3 && box2.size() <= 3) {
117                     Bread b1 = box1.pop();
118                     System.out.println(Thread.currentThread().getName()
119                             + "-> box1 : " + b1);
120                 } else {
121                     Random ran = new Random();
122                     int num = ran.nextInt(2);
123                     if (num == 0) {
124                         Bread b1 = box1.pop();
125                         System.out.println(Thread.currentThread().getName()
126                                 + "-> box1 : " + b1);
127                     } else {
128                         Bread b2 = box2.pop();
129                         System.out.println(Thread.currentThread().getName()
130                                 + "-> box2 : " + b2);
131                     }
132
133                 }
134             }
135         }
136     }
137 }
138
139 class Box {
140     LinkedList<Bread> list = new LinkedList<Bread>();
141     int maxNum = 20;
142
143     public void push(Bread b) {
144         if (list.size() < maxNum) {
145             list.add(b);
146         }
147
148     }
149
150     public Bread pop() {
151         if (list.size() > 0) {
152             return list.remove();
153         }
154         return null;
155     }
156
157     public int size() {
158         return list.size();
159     }
160 }
161
162 class Bread {
163     private String sid;
164
165     Bread(String sid) {
166         this.sid = sid;
167     }
168
169     @Override
170     public String toString() {
171         return "sid= " + sid;
172     }
173
174 }