JAVA線程15 - 新特性:阻塞隊列&阻塞棧

1、阻塞隊列

1. 概述

阻塞隊列是Java5線程新特徵中的內容,Java定義了阻塞隊列的接口java.util.concurrent.BlockingQueue。 java

阻塞隊列是一個指定長度的隊列,若是隊列滿了,添加新元素的操做會被阻塞等待,直到有空位爲止。一樣,當隊列爲空時候,請求隊列元素的操做一樣會阻塞等待,直到有可用元素爲止。 dom

遵循先進先出的原則。 線程

阻塞隊列有不少實現類,用來知足各類複雜的需求:ArrayBlockingQueue, DelayQueue, LinkedBlockingQueue, PriorityBlockingQueue,SynchronousQueue ,API差異也很小。 code

2. 示例

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();
    }
}

2、阻塞棧

對於阻塞棧,與阻塞隊列類似。不一樣點在於棧是「後入先出」的結構,每次操做的是棧頂,而隊列是「先進先出」的結構,每次操做的是隊列頭。 接口

這裏要特別說明一點的是,阻塞棧是Java6的新特徵。 隊列

Java爲阻塞棧定義了接口:java.util.concurrent.BlockingDeque,其實現類也比較多,具體能夠查看JavaAPI文檔。