1 import java.util.concurrent.ArrayBlockingQueue;
 2 import java.util.concurrent.BlockingQueue;
 3 public class BlockingQueueTest{
 4     public static void main(String[] args)throws Exception{
 5         //创建一个容量为1的BlockingQueue
 6
 7         BlockingQueue<String> b=new ArrayBlockingQueue<>(1);
 8         //启动3个生产者线程
 9         new Producer(b).start();
10         new Producer(b).start();
11         new Producer(b).start();
12         //启动一个消费者线程
13         new Consumer(b).start();
14
15     }
16 }
17 class Producer extends Thread{
18     private BlockingQueue<String> b;
19
20     public Producer(BlockingQueue<String> b){
21         this.b=b;
22
23     }
24     public synchronized void run(){
25         String [] str=new String[]{
26             "java",
27             "struts",
28             "Spring"
29         };
30         for(int i=0;i<9999999;i++){
31             System.out.println(getName()+"生产者准备生产集合元素！");
32             try{
33
34                 b.put(str[i%3]);
35                 sleep(1000);
36                 //尝试放入元素，如果队列已满，则线程被阻塞
37
38             }catch(Exception e){System.out.println(e);}
39             System.out.println(getName()+"生产完成："+b);
40         }
41
42     }
43 }
44 class Consumer extends Thread{
45     private BlockingQueue<String> b;
46     public Consumer(BlockingQueue<String> b){
47         this.b=b;
48     }
49     public  synchronized  void run(){
50
51         while(true){
52             System.out.println(getName()+"消费者准备消费集合元素！");
53             try{
54                 sleep(1000);
55                 //尝试取出元素，如果队列已空，则线程被阻塞
56                 b.take();
57             }catch(Exception e){System.out.println(e);}
58             System.out.println(getName()+"消费完："+b);
59         }
60
61     }
62 }