Java使用阻塞队列控制线程通信的方法实例详解

import java.util.concurrent.*;
public class BlockingQueueTest
{
   public static void main(String[] args)
      throws Exception
   {
      // 定义一个长度为2的阻塞队列
      BlockingQueue<String> bq = new ArrayBlockingQueue<>(2);
      bq.put("Java"); // 与bq.add("Java"、bq.offer("Java")相同
      bq.put("Java"); // 与bq.add("Java"、bq.offer("Java")相同
      System.out.println("打印1");
      bq.put("Java"); // ① 阻塞线程。
      System.out.println("打印2");
   }
}

import java.util.concurrent.*;
public class BlockingQueueTest
{
   public static void main(String[] args)
      throws Exception
   {
      // 定义一个长度为2的阻塞队列
      BlockingQueue<String> bq = new ArrayBlockingQueue<>(2);
      bq.put("Java"); // 与bq.add("Java"、bq.offer("Java")相同
      bq.put("Java"); // 与bq.add("Java"、bq.offer("Java")相同
      System.out.println("打印1");
      //bq.put("Java"); // ① 阻塞线程。
      System.out.println("打印2");
   }
}

import java.util.concurrent.*;
class Producer extends Thread
{
   private BlockingQueue<String> bq;
   public Producer(BlockingQueue<String> bq)
   {
      this.bq = bq;
   }
   public void run()
   {
      String[] strArr = new String[]
      {
        "Java",
        "Struts",
        "Spring"
      };
      for (int i = 0 ; i < 5 ; i++ )
      {
        System.out.println(getName() + "生产者准备生产集合元素！");
        try
        {
           Thread.sleep(200);
           // 尝试放入元素，如果队列已满，线程被阻塞
           bq.put(strArr[i % 3]);
        }
        catch (Exception ex){ex.printStackTrace();}
        System.out.println(getName() + "生产完成：" + bq);
      }
   }
}
class Consumer extends Thread
{
   private BlockingQueue<String> bq;
   public Consumer(BlockingQueue<String> bq)
   {
      this.bq = bq;
   }
   public void run()
   {
      while(true)
      {
        System.out.println(getName() + "消费者准备消费集合元素！");
        try
        {
           Thread.sleep(200);
           // 尝试取出元素，如果队列已空，线程被阻塞
           bq.take();
        }
        catch (Exception ex){ex.printStackTrace();}
        System.out.println(getName() + "消费完成：" + bq);
      }
   }
}
public class BlockingQueueTest2
{
   public static void main(String[] args)
   {
      // 创建一个容量为1的BlockingQueue
      BlockingQueue<String> bq = new ArrayBlockingQueue<>(1);
      // 启动3条生产者线程
      new Producer(bq).start();
      new Producer(bq).start();
      new Producer(bq).start();
      // 启动一条消费者线程
      new Consumer(bq).start();
   }
}