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(3);
  for(int i=0;i<2;i++){
   new Thread(){
    public void run(){
     while(true){
      try {
       Thread.sleep((long)(Math.random()*1000));
       System.out.println(Thread.currentThread().getName() + "準備放數據!");       
       queue.put(1);
       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(1000);
      System.out.println(Thread.currentThread().getName() + "準備取數據!");
      queue.take();
      System.out.println(Thread.currentThread().getName() + "已經取走數據，" +        
        "隊列目前有" + queue.size() + "個數據");     
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
    }
   }
   
  }.start();   
 }
}