/**
* Created by niehongtao on 16/7/14.
*/publicclassProduct {privateint id;
publicProduct(int id) {
this.id = id;
}
public String toString() {// 重写toString方法return"产品:" + this.id;
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
客户端
/**
* Created by niehongtao on 16/7/14.
*/publicclassProducerConsumer {publicstaticvoidmain(String[] args) {
BlockingQueue<Product> queues = new LinkedBlockingQueue<Product>(10);
ExecutorService service = Executors.newCachedThreadPool();
Producer p = new Producer("张三", queues);
Producer p2 = new Producer("李四", queues);
Consumer c = new Consumer("王五", queues);
Consumer c2 = new Consumer("老刘", queues);
Consumer c3 = new Consumer("老林", queues);
service.submit(p);
service.submit(p2);
service.submit(c);
service.submit(c2);
service.submit(c3);
}
}