好久沒有寫文章了，這段時(shí)間事情比較雜，工作也比較雜亂，上周日剛搬完家，從自建房搬到了樓房，提升了一層生活品質(zhì)，哈哈！不過昨天晚上在公交車上錢包被偷了，前段時(shí)間還丟個(gè)自行車，不得不感嘆，京城扒手真多，還無人處理。言歸正傳，這一段時(shí)間我的工作主要是改進(jìn)公司的調(diào)度器，調(diào)度器調(diào)度線程池執(zhí)行任務(wù)，生產(chǎn)者生產(chǎn)任務(wù)，消費(fèi)者消費(fèi)任務(wù)，那么這時(shí)就需要一個(gè)任務(wù)隊(duì)列，生產(chǎn)者向隊(duì)列里插入任務(wù)，消費(fèi)者從隊(duì)列里提取任務(wù)執(zhí)行，調(diào)度器里是通過BlockingQueue實(shí)現(xiàn)的隊(duì)列，隨后小查一下，下面看看BlockingQueue的原理及其方法。

       BlockingQueue最終會(huì)有四種狀況，拋出異常、返回特殊值、阻塞、超時(shí)，下表總結(jié)了這些方法：

	拋出異常	特殊值	阻塞	超時(shí)
插入	add(e)	offer(e)	put(e)	offer(e, time, unit)
移除	remove()	poll()	take()	poll(time, unit)
檢查	element()	peek()	不可用	不可用

       BlockingQueue是個(gè)接口，有如下實(shí)現(xiàn)類：

       1. ArrayBlockQueue：一個(gè)由數(shù)組支持的有界阻塞隊(duì)列。此隊(duì)列按 FIFO（先進(jìn)先出）原則對元素進(jìn)行排序。創(chuàng)建其對象必須明確大小，像數(shù)組一樣。

       2. LinkedBlockQueue：一個(gè)可改變大小的阻塞隊(duì)列。此隊(duì)列按 FIFO（先進(jìn)先出）原則對元素進(jìn)行排序。創(chuàng)建其對象如果沒有明確大小，默認(rèn)值是Integer.MAX_VALUE。鏈接隊(duì)列的吞吐量通常要高于基于數(shù)組的隊(duì)列，但是在大多數(shù)并發(fā)應(yīng)用程序中，其可預(yù)知的性能要低。 

       3. PRiorityBlockingQueue：類似于LinkedBlockingQueue，但其所含對象的排序不是FIFO，而是依據(jù)對象的自然排序順序或者是構(gòu)造函數(shù)所帶的Comparator決定的順序。

       4. SynchronousQueue：同步隊(duì)列。同步隊(duì)列沒有任何容量，每個(gè)插入必須等待另一個(gè)線程移除，反之亦然。

       下面使用ArrayBlockQueue來實(shí)現(xiàn)之前實(shí)現(xiàn)過的生產(chǎn)者消/費(fèi)者模式，代碼如下：

[java] view plain copy print?/** 定義一個(gè)盤子類，可以放雞蛋和取雞蛋 */  public class BigPlate {        /** 裝雞蛋的盤子，大小為5 */      private BlockingQueue<Object> eggs = new ArrayBlockingQueue<Object>(5);            /** 放雞蛋 */      public void putEgg(Object egg) {          try {              eggs.put(egg);// 向盤子末尾放一個(gè)雞蛋，如果盤子滿了，當(dāng)前線程阻塞          } catch (InterruptedException e) {              e.printStackTrace();          }            // 下面輸出有時(shí)不準(zhǔn)確，因?yàn)榕cput操作不是一個(gè)原子操作          System.out.println("放入雞蛋");      }            /** 取雞蛋 */      public Object getEgg() {          Object egg = null;          try {              egg = eggs.take();// 從盤子開始取一個(gè)雞蛋，如果盤子空了，當(dāng)前線程阻塞          } catch (InterruptedException e) {              e.printStackTrace();          }            // 下面輸出有時(shí)不準(zhǔn)確，因?yàn)榕ctake操作不是一個(gè)原子操作          System.out.println("拿到雞蛋");          return egg;      }            /** 放雞蛋線程 */      static class AddThread extends Thread {          private BigPlate plate;          private Object egg = new Object();            public AddThread(BigPlate plate) {              this.plate = plate;          }            public void run() {              plate.putEgg(egg);          }      }        /** 取雞蛋線程 */      static class GetThread extends Thread {          private BigPlate plate;            public GetThread(BigPlate plate) {              this.plate = plate;          }            public void run() {              plate.getEgg();          }      }            public static void main(String[] args) {          BigPlate plate = new BigPlate();          // 先啟動(dòng)10個(gè)放雞蛋線程          for(int i = 0; i < 10; i++) {              new Thread(new AddThread(plate)).start();          }          // 再啟動(dòng)10個(gè)取雞蛋線程          for(int i = 0; i < 10; i++) {              new Thread(new GetThread(plate)).start();          }      }  }   %20 %20 %20 執(zhí)行結(jié)果：

[plain] view%20plain copy print?放入雞蛋  放入雞蛋  放入雞蛋  放入雞蛋  放入雞蛋  拿到雞蛋  放入雞蛋  拿到雞蛋  拿到雞蛋  拿到雞蛋  放入雞蛋  放入雞蛋  放入雞蛋  拿到雞蛋  放入雞蛋  拿到雞蛋  拿到雞蛋  拿到雞蛋  拿到雞蛋  拿到雞蛋         從結(jié)果看，啟動(dòng)10個(gè)放雞蛋線程和10個(gè)取雞蛋線程，前5個(gè)放入雞蛋的線程成功執(zhí)行，到第6個(gè)，發(fā)現(xiàn)盤子滿了，阻塞住，這時(shí)切換到取雞蛋線程執(zhí)行，成功實(shí)現(xiàn)了生產(chǎn)者/消費(fèi)者模式。java.util.concurrent包是個(gè)強(qiáng)大的包！

        本文來自：高爽|Coder，原文地址：http://blog.csdn.net/ghsau/article/details/8108292。