阻塞隊列是Java5線程新特徵中的內容,Java定義了阻塞隊列的接口java.util.concurrent.BlockingQueue。 java
阻塞隊列是一個指定長度的隊列,若是隊列滿了,添加新元素的操做會被阻塞等待,直到有空位爲止。一樣,當隊列爲空時候,請求隊列元素的操做一樣會阻塞等待,直到有可用元素爲止。 dom
遵循先進先出的原則。 線程
阻塞隊列有不少實現類,用來知足各類複雜的需求:ArrayBlockingQueue, DelayQueue, LinkedBlockingQueue, PriorityBlockingQueue,SynchronousQueue ,API差異也很小。 code
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; public class BlockingQueueTest { public static void main(String[] args) { final BlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(5); 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(); } }
對於阻塞棧,與阻塞隊列類似。不一樣點在於棧是「後入先出」的結構,每次操做的是棧頂,而隊列是「先進先出」的結構,每次操做的是隊列頭。 接口
這裏要特別說明一點的是,阻塞棧是Java6的新特徵。 隊列
Java爲阻塞棧定義了接口:java.util.concurrent.BlockingDeque,其實現類也比較多,具體能夠查看JavaAPI文檔。