BlockingQueue实现阻塞队列

 import java.util.concurrent.ArrayBlockingQueue;

 import java.util.concurrent.BlockingQueue;

 public class BlockingQueueTest {

     public static void main(String[] args) {

         final BlockingQueue queue = new ArrayBlockingQueue(); //队列长度

         for(int i=;i<;i++){

             new Thread(){

                 public void run(){

                     while(true){

                         try {

                             Thread.sleep((long)(Math.random()*));

                             System.out.println(Thread.currentThread().getName() + "准备放数据!");

                             queue.put(); //放数据

                             System.out.println(Thread.currentThread().getName() + "已经放了数据，" +

                                         "队列目前有" + queue.size() + "个数据");

                         } catch (InterruptedException e) {

                             e.printStackTrace();

                         }

                     }

                 }

             }.start();

         }

         new Thread(){

             public void run(){

                 while(true){

                     try {

                         //将此处的睡眠时间分别改为100和1000，观察运行结果

                         Thread.sleep();

                         System.out.println(Thread.currentThread().getName() + "准备取数据!");

                         queue.take(); //取数据

                         System.out.println(Thread.currentThread().getName() + "已经取走数据，" +

                                 "队列目前有" + queue.size() + "个数据");

                     } catch (InterruptedException e) {

                         e.printStackTrace();

                     }

                 }

             }

         }.start();

     }

 }

测试如下：

Thread-1准备放数据!

Thread-1已经放了数据，队列目前有1个数据

Thread-0准备放数据!

Thread-0已经放了数据，队列目前有2个数据

Thread-2准备取数据!

Thread-2已经取走数据，队列目前有1个数据

Thread-1准备放数据!

Thread-1已经放了数据，队列目前有2个数据

Thread-0准备放数据!

Thread-0已经放了数据，队列目前有3个数据

Thread-1准备放数据!