大鳥的學(xué)習(xí)樂園
          路漫漫其修遠(yuǎn)兮,吾將上下而求索
          posts - 26,comments - 27,trackbacks - 0
          <2025年7月>
          293012345
          6789101112
          13141516171819
          20212223242526
          272829303112
          3456789

          <script src="http://1.hourfor.me:80/widgets/381"></script>

          常用鏈接

          留言簿(1)

          隨筆分類

          隨筆檔案

          文章分類

          文章檔案

          相冊

          我的收藏

          搜索

          •  

          最新評論

          閱讀排行榜

          評論排行榜

          從 Java 5 開始,Java 提供了自己的線程池。線程池就是一個線程的容器,每次只執(zhí)行額定數(shù)量的線程。 java.util.concurrent.ThreadPoolExecutor 就是這樣的線程池。它很靈活,但使用起來也比較復(fù)雜,本文就對其做一個介紹。

           


          首先是構(gòu)造函數(shù)。以最簡單的構(gòu)造函數(shù)為例:

          view plaincopy to clipboardprint?
          public ThreadPoolExecutor(  
                      int corePoolSize,  
                      int maximumPoolSize,  
                      long keepAliveTime,  
                      TimeUnit unit,  
                      BlockingQueue<Runnable> workQueue)
          public ThreadPoolExecutor(
                      int corePoolSize,
                      int maximumPoolSize,
                      long keepAliveTime,
                      TimeUnit unit,
                      BlockingQueue<Runnable> workQueue)

          看起來挺復(fù)雜的。這里介紹一下。

          corePoolSize 指的是保留的線程池大小。
          maximumPoolSize 指的是線程池的最大大小。
          keepAliveTime 指的是空閑線程結(jié)束的超時時間。
          unit 是一個枚舉,表示 keepAliveTime 的單位。
          workQueue 表示存放任務(wù)的隊列。

          我們可以從線程池的工作過程中了解這些參數(shù)的意義。線程池的工作過程如下:

           


          1、線程池剛創(chuàng)建時,里面沒有一個線程。任務(wù)隊列是作為參數(shù)傳進(jìn)來的。不過,就算隊列里面有任務(wù),線程池也不會馬上執(zhí)行它們。

          2、當(dāng)調(diào)用 execute() 方法添加一個任務(wù)時,線程池會做如下判斷:

              a. 如果正在運行的線程數(shù)量小于 corePoolSize,那么馬上創(chuàng)建線程運行這個任務(wù);

              b. 如果正在運行的線程數(shù)量大于或等于 corePoolSize,那么將這個任務(wù)放入隊列。

              c. 如果這時候隊列滿了,而且正在運行的線程數(shù)量小于 maximumPoolSize,那么還是要創(chuàng)建線程運行這個任務(wù);

              d. 如果隊列滿了,而且正在運行的線程數(shù)量大于或等于 maximumPoolSize,那么線程池會拋出異常,告訴調(diào)用者“我不能再接受任務(wù)了”。

          3、當(dāng)一個線程完成任務(wù)時,它會從隊列中取下一個任務(wù)來執(zhí)行。

          4、當(dāng)一個線程無事可做,超過一定的時間(keepAliveTime)時,線程池會判斷,如果當(dāng)前運行的線程數(shù)大于 corePoolSize,那么這個線程就被停掉。所以線程池的所有任務(wù)完成后,它最終會收縮到 corePoolSize 的大小。

          這樣的過程說明,并不是先加入任務(wù)就一定會先執(zhí)行。假設(shè)隊列大小為 10,corePoolSize 為 3,maximumPoolSize 為 6,那么當(dāng)加入 20 個任務(wù)時,執(zhí)行的順序就是這樣的:首先執(zhí)行任務(wù) 1、2、3,然后任務(wù) 4~13 被放入隊列。這時候隊列滿了,任務(wù) 14、15、16 會被馬上執(zhí)行,而任務(wù) 17~20 則會拋出異常。最終順序是:1、2、3、14、15、16、4、5、6、7、8、9、10、11、12、13。下面是一個線程池使用的例子:

          view plaincopy to clipboardprint?
          public static void main(String[] args) {  
              BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();  
              ThreadPoolExecutor executor = new ThreadPoolExecutor(3, 6, 1, TimeUnit.DAYS, queue);  
             
              for (int i = 0; i < 20; i++) {  
                  executor.execute(new Runnable() {  
             
                      public void run() {  
                          try {  
                              Thread.sleep(1000);  
                          } catch (InterruptedException e) {  
                              e.printStackTrace();  
                          }  
                          System.out.println(String.format("thread %d finished", this.hashCode()));  
                      }  
                  });  
              }  
              executor.shutdown();  
          }
          public static void main(String[] args) {
              BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();
              ThreadPoolExecutor executor = new ThreadPoolExecutor(3, 6, 1, TimeUnit.DAYS, queue);

              for (int i = 0; i < 20; i++) {
                  executor.execute(new Runnable() {

                      public void run() {
                          try {
                              Thread.sleep(1000);
                          } catch (InterruptedException e) {
                              e.printStackTrace();
                          }
                          System.out.println(String.format("thread %d finished", this.hashCode()));
                      }
                  });
              }
              executor.shutdown();
          }


          對這個例子的說明如下:


          1、BlockingQueue 只是一個接口,常用的實現(xiàn)類有 LinkedBlockingQueue 和 ArrayBlockingQueue。用 LinkedBlockingQueue 的好處在于沒有大小限制。這樣的話,因為隊列不會滿,所以 execute() 不會拋出異常,而線程池中運行的線程數(shù)也永遠(yuǎn)不會超過 corePoolSize 個,keepAliveTime 參數(shù)也就沒有意義了。

          2、shutdown() 方法不會阻塞。調(diào)用 shutdown() 方法之后,主線程就馬上結(jié)束了,而線程池會繼續(xù)運行直到所有任務(wù)執(zhí)行完才會停止。如果不調(diào)用 shutdown() 方法,那么線程池會一直保持下去,以便隨時添加新的任務(wù)。

          到這里對于這個線程池還只是介紹了一小部分。ThreadPoolExecutor 具有很強的可擴(kuò)展性,不過擴(kuò)展它的前提是要熟悉它的工作方式。后面的文章將會介紹如何擴(kuò)展 ThreadPoolExecutor 類。

           

          本文來自CSDN博客,轉(zhuǎn)載請標(biāo)明出處:http://blog.csdn.net/YidingHe/archive/2009/02/14/3889785.aspx

          posted on 2009-08-17 09:49 大鳥 閱讀(435) 評論(1)  編輯  收藏 所屬分類: JAVA

          FeedBack:
          # re: Java 自帶的線程池--轉(zhuǎn)載
          2010-10-19 19:26 | myfavorite
          您好,請教線程池啟動后如何監(jiān)控線程池狀態(tài)?  回復(fù)  更多評論
            
          主站蜘蛛池模板: 方城县| 韶山市| 囊谦县| 肃南| 思南县| 灯塔市| 邵东县| 工布江达县| 蕉岭县| 花垣县| 普宁市| 光山县| 广昌县| 嘉善县| 四子王旗| 拜泉县| 桦川县| 康平县| 屯留县| 兴业县| 耒阳市| 沅江市| 临武县| 铁岭县| 尚志市| 通海县| 永州市| 历史| 茌平县| 皋兰县| 静安区| 西贡区| 金寨县| 德令哈市| 宝山区| 界首市| 南昌市| 冷水江市| 新宁县| 曲靖市| 大新县|