Callable、Future&阻塞隊列&阻塞棧

時間 2019-11-11

標籤 callable future 阻塞隊列简体版

原文原文鏈接

Callable、Future 簡單應用

在Java5以前，線程是沒有返回值的，經常爲了「有」返回值，破費周折，並且代碼很很差寫。或者乾脆繞過這道坎，走別的路了。如今Java終於有可返回值的任務（也能夠叫作線程）了。java

可返回值的任務必須實現Callable接口，相似的，無返回值的任務必須Runnable接口。執行Callable任務後，能夠獲取一個Future的對象，在該對象上調用get就能夠獲取到Callable任務返回的Object了。多線程

Code

public class Test { 
        public static void main(String[] args) throws ExecutionException, InterruptedException { 
                //建立一個線程池 
                ExecutorService pool = Executors.newFixedThreadPool(2); 
                //建立兩個有返回值的任務 
                Callable c1 = new MyCallable("A"); 
                Callable c2 = new MyCallable("B"); 
                //執行任務並獲取Future對象 
                Future f1 = pool.submit(c1); 
                Future f2 = pool.submit(c2); 
                //從Future對象上獲取任務的返回值，並輸出到控制檯 
                System.out.println(">>>"+f1.get().toString()); 
                System.out.println(">>>"+f2.get().toString()); 
                //關閉線程池 
                pool.shutdown(); 
        } 
} 

class MyCallable implements Callable{ 
        private String oid; 

        MyCallable(String oid) { 
                this.oid = oid; 
        } 

        @Override 
        public Object call() throws Exception { 
                return oid+"任務返回的內容"; 
        } 
}

>>>A任務返回的內容 
>>>B任務返回的內容

阻塞隊列簡單應用

阻塞隊列是Java5線程新特徵中的內容，Java定義了阻塞隊列的接口java.util.concurrent.BlockingQueue，阻塞隊列的概念是，一個指定長度的隊列，若是隊列滿了，添加新元素的操做會被阻塞等待，直到有空位爲止。一樣，當隊列爲空時候，請求隊列元素的操做一樣會阻塞等待，直到有可用元素爲止。ide

有了這樣的功能，就爲多線程的排隊等候的模型實現開闢了便捷通道，很是有用。this

Code

public class Test { 
        public static void main(String[] args) throws InterruptedException { 
                BlockingQueue bqueue = new ArrayBlockingQueue(20); 
                for (int i = 0; i < 30; i++) { 
                        //將指定元素添加到此隊列中，若是沒有可用空間，將一直等待（若是有必要）。 
                        bqueue.put(i); 
                        System.out.println("向阻塞隊列中添加了元素:" + i); 
                } 
                System.out.println("程序到此運行結束，即將退出----"); 
        } 
}

向阻塞隊列中添加了元素:0 
向阻塞隊列中添加了元素:1 
向阻塞隊列中添加了元素:2 
向阻塞隊列中添加了元素:3 
向阻塞隊列中添加了元素:4 
向阻塞隊列中添加了元素:5 
向阻塞隊列中添加了元素:6 
向阻塞隊列中添加了元素:7 
向阻塞隊列中添加了元素:8 
向阻塞隊列中添加了元素:9 
向阻塞隊列中添加了元素:10 
向阻塞隊列中添加了元素:11 
向阻塞隊列中添加了元素:12 
向阻塞隊列中添加了元素:13 
向阻塞隊列中添加了元素:14 
向阻塞隊列中添加了元素:15 
向阻塞隊列中添加了元素:16 
向阻塞隊列中添加了元素:17 
向阻塞隊列中添加了元素:18 
向阻塞隊列中添加了元素:19

能夠看出，輸出到元素19時候，就一直處於等待狀態，由於隊列滿了，程序阻塞了。spa

阻塞棧簡單應用

對於阻塞棧，與阻塞隊列類似。不一樣點在於棧是「後入先出」的結構，每次操做的是棧頂，而隊列是「先進先出」的結構，每次操做的是隊列頭。Java爲阻塞棧定義了接口：java.util.concurrent.BlockingDeque。線程

Code

public class Test { 
        public static void main(String[] args) throws InterruptedException { 
                BlockingDeque bDeque = new LinkedBlockingDeque(20); 
                for (int i = 0; i < 30; i++) { 
                        //將指定元素添加到此阻塞棧中，若是沒有可用空間，將一直等待（若是有必要）。 
                        bDeque.putFirst(i); 
                        System.out.println("向阻塞棧中添加了元素:" + i); 
                } 
                System.out.println("程序到此運行結束，即將退出----"); 
        } 
}

向阻塞棧中添加了元素:0 
向阻塞棧中添加了元素:1 
向阻塞棧中添加了元素:2 
向阻塞棧中添加了元素:3 
向阻塞棧中添加了元素:4 
向阻塞棧中添加了元素:5 
向阻塞棧中添加了元素:6 
向阻塞棧中添加了元素:7 
向阻塞棧中添加了元素:8 
向阻塞棧中添加了元素:9 
向阻塞棧中添加了元素:10 
向阻塞棧中添加了元素:11 
向阻塞棧中添加了元素:12 
向阻塞棧中添加了元素:13 
向阻塞棧中添加了元素:14 
向阻塞棧中添加了元素:15 
向阻塞棧中添加了元素:16 
向阻塞棧中添加了元素:17 
向阻塞棧中添加了元素:18 
向阻塞棧中添加了元素:19