線程池

系統(tǒng)啟動(dòng)一個(gè)新線程的成本是比較高的，因?yàn)樗婕暗脚c操作系統(tǒng)的交互。在這種情況下，使用線程池可以很好的提供性能，尤其是當(dāng)程序中需要?jiǎng)?chuàng)建大量生存期很短暫的線程時(shí)，更應(yīng)該考慮使用線程池。

與數(shù)據(jù)庫連接池類似的是，線程池在系統(tǒng)啟動(dòng)時(shí)即創(chuàng)建大量空閑的線程，程序?qū)⒁粋€(gè)Runnable對象傳給線程池，線程池就會(huì)啟動(dòng)一條線程來執(zhí)行該對象的run方法，當(dāng)run方法執(zhí)行結(jié)束后，該線程并不會(huì)死亡，而是再次返回線程池中成為空閑狀態(tài)，等待執(zhí)行下一個(gè)Runnable對象的run方法。

除此之外，使用線程池可以有效地控制系統(tǒng)中并發(fā)線程的數(shù)量，但系統(tǒng)中包含大量并發(fā)線程時(shí)，會(huì)導(dǎo)致系統(tǒng)性能劇烈下降，甚至導(dǎo)致JVM崩潰。而線程池的最大線程數(shù)參數(shù)可以控制系統(tǒng)中并發(fā)的線程不超過此數(shù)目。

在JDK1.5之前，開發(fā)者必須手動(dòng)的實(shí)現(xiàn)自己的線程池，從JDK1.5之后，Java內(nèi)建支持線程池。

與多線程并發(fā)的所有支持的類都在java.util.concurrent包中。我們可以使用里面的類更加的控制多線程的執(zhí)行。

系統(tǒng)啟動(dòng)一個(gè)新線程的成本是比較高的，因?yàn)樗婕暗脚c操作系統(tǒng)的交互。在這種情況下，使用線程池可以很好的提供性能，尤其是當(dāng)程序中需要?jiǎng)?chuàng)建大量生存期很短暫的線程時(shí)，更應(yīng)該考慮使用線程池

JDK1.5中提供Executors工廠類來產(chǎn)生連接池，該工廠類中包含如下的幾個(gè)靜態(tài)工程方法來創(chuàng)建連接池：

1、public static ExecutorService newFixedThreadPool(int nThreads)：創(chuàng)建一個(gè)可重用的、具有固定線程數(shù)的線程池。

2、public static ExecutorService newSingleThreadExecutor()：創(chuàng)建一個(gè)只有單線程的線程池，它相當(dāng)于newFixedThreadPool方法是傳入的參數(shù)為1

3、public static ExecutorService newCachedThreadPool()：創(chuàng)建一個(gè)具有緩存功能的線程池，系統(tǒng)根據(jù)需要?jiǎng)?chuàng)建線程，這些線程將會(huì)被緩存在線程池中。

4、public static ScheduledExecutorService newSingleThreadScheduledExecutor：創(chuàng)建只有一條線程的線程池，他可以在指定延遲后執(zhí)行線程任務(wù)

5、public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)：創(chuàng)建具有指定線程數(shù)的線程池，它可以再指定延遲后執(zhí)行線程任務(wù)，corePoolSize指池中所保存的線程數(shù)，即使線程是空閑的也被保存在線程池內(nèi)。

上面的幾個(gè)方法都有一個(gè)重載的方法，多傳入一個(gè)ThreadFactory參數(shù)的重載方法，使用的比較少。

二、ExecutorService類

可以看到上面的5個(gè)方法中，前面3個(gè)方法的返回值都是一個(gè)ExecutorService對象。該ExecutorService對象就代表著一個(gè)盡快執(zhí)行線程的線程池（只要線程池中有空閑線程立即執(zhí)行線程任務(wù)），程序只要將一個(gè)Runnable對象或Callable對象提交給該線程池即可，該線程就會(huì)盡快的執(zhí)行該任務(wù)。

ExecutorService有幾個(gè)重要的方法：

更詳細(xì)的參考JDK API文檔。

submit方法是對 Executor接口execute方法的更好的封裝，建議使用submit方法。

三、ScheduleExecutorService類

在上面的5個(gè)方法中，后面2個(gè)方法的返回值都是一個(gè)ScheduleExecutorService對象。ScheduleExecutorService代表可在指定延遲或周期性執(zhí)行線程任務(wù)的線程池。

ScheduleExecutorService類是ExecutorService類的子類。所以，它里面也有直接提交任務(wù)的submit方法，并且新增了一些延遲任務(wù)處理的方法：

下面看看線程池的簡單使用：

1、固定大小的線程池：

package com.bjpowernode.test; 
 import java.util.concurrent.ExecutorService; 
 import java.util.concurrent.Executors; 
 public class PoolTest { 
 public static void main(String[] args) { 
  ExecutorService pool=Executors.newFixedThreadPool(5);//創(chuàng)建一個(gè)固定大小為5的線程池 
  for(int i=0;i<7;i++){ 
  pool.submit(new MyThread()); 
  } 
  pool.shutdown(); 
 } 
 } 
 class MyThread extends Thread{ 
 @Override 
 public void run() { 
  System.out.println(Thread.currentThread().getName()+"正在執(zhí)行。。。"); 
 } 
 } 

輸出結(jié)果：

 pool-1-thread-1正在執(zhí)行。。。 
 pool-1-thread-3正在執(zhí)行。。。 
 pool-1-thread-2正在執(zhí)行。。。 
 pool-1-thread-4正在執(zhí)行。。。 
 pool-1-thread-4正在執(zhí)行。。。 
 pool-1-thread-5正在執(zhí)行。。。 
 pool-1-thread-1正在執(zhí)行。。。 

可以看到雖然我們呢創(chuàng)建了7個(gè)MyThread線程對象，但是由于受線程池的大小限制，只是開啟了5個(gè)線程，這樣就減少了并發(fā)線程的數(shù)量。

2、單任務(wù)線程池：

 public class PoolTest { 
 public static void main(String[] args) { 
  ExecutorService pool=Executors.newSingleThreadExecutor();//創(chuàng)建一個(gè)單線程池 
  for(int i=0;i<7;i++){ 
  pool.submit(new MyThread()); 
  } 
  pool.shutdown(); 
 } 
 }

輸出結(jié)果：

 pool-1-thread-1正在執(zhí)行。。。 
 pool-1-thread-1正在執(zhí)行。。。 
 pool-1-thread-1正在執(zhí)行。。。 
 pool-1-thread-1正在執(zhí)行。。。 
 pool-1-thread-1正在執(zhí)行。。。 
 pool-1-thread-1正在執(zhí)行。。。 
 pool-1-thread-1正在執(zhí)行。。。 

可以看到，線程池只開啟了一個(gè)線程。

3、創(chuàng)建可變尺寸的線程池

 public class PoolTest { 
 public static void main(String[] args) { 
  ExecutorService pool=Executors.newCachedThreadPool(); 
  for(int i=0;i<5;i++){ 
  pool.submit(new MyThread()); 
  } 
  pool.shutdown(); 
 } 
 } 

看輸出結(jié)果：

 pool-1-thread-1正在執(zhí)行。。。 
 pool-1-thread-3正在執(zhí)行。。。 
 pool-1-thread-2正在執(zhí)行。。。 
 pool-1-thread-4正在執(zhí)行。。。 
 pool-1-thread-5正在執(zhí)行。。。 

可以看到，我們沒有限制線程池的大小，但是它會(huì)根據(jù)需求而創(chuàng)建線程。

4、延遲線程池

 public class PoolTest { 
 public static void main(String[] args) { 
  ScheduledExecutorService pool=Executors.newScheduledThreadPool(6); 
  for(int i=0;i<4;i++){ 
  pool.submit(new MyThread()); 
  } 
  
  pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS); 
  pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS); 
  pool.shutdown(); 
 } 
 } 

輸出結(jié)果：

pool-1-thread-1正在執(zhí)行。。。 
pool-1-thread-3正在執(zhí)行。。。 
pool-1-thread-2正在執(zhí)行。。。 
 pool-1-thread-4正在執(zhí)行。。。 
 pool-1-thread-6正在執(zhí)行。。。 
pool-1-thread-1正在執(zhí)行。。。 

可以明顯看到，最后兩個(gè)線程不是立即執(zhí)行，而是延遲了1秒在執(zhí)行的。

5、單任務(wù)延遲線程池

 public class PoolTest { 
 public static void main(String[] args) { 
  ScheduledExecutorService pool=Executors.newSingleThreadScheduledExecutor(); 
  for(int i=0;i<4;i++){ 
  pool.submit(new MyThread()); 
  } 
  
  pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS); 
  pool.schedule(new MyThread(), 1000, TimeUnit.MILLISECONDS); 
  pool.shutdown(); 
 } 
 } 

上面我們使用的是JDK幫我封裝好的線程池，我們也可以自己定義線程池，查看源碼，我們發(fā)現(xiàn)，Excutors里面的獲得線程的靜態(tài)方法，內(nèi)部都是調(diào)用ThreadPoolExecutor的構(gòu)造方法。比如：

 public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) { 
 return new ThreadPoolExecutor(nThreads, nThreads, 
     0L, TimeUnit.MILLISECONDS, 
     new LinkedBlockingQueue<Runnable>(), 
     threadFactory); 
 } 

可以看到，它是通過調(diào)用ThreadPoolExecutor的構(gòu)造方法來返回一個(gè)線程池的。所以，我們也可以自己手動(dòng)的調(diào)用ThreadPoolExecutor的各種構(gòu)造方法，來定義自己的線程池規(guī)則，不過一般情況下，使用自帶的線程池就夠了，不需要自己來實(shí)現(xiàn)。

以上所述是小編給大家介紹的Java 線程池，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！

最新評論