什么原因使我們不得不使用線程池？
個(gè)人認(rèn)為主要原因是：短時(shí)間內(nèi)需要處理的任務(wù)數(shù)量很多
使用線程池的好處:
1.減少在創(chuàng)建和銷毀線程上所花的時(shí)間以及系統(tǒng)資源的開銷
2.如不使用線程池，有可能造成系統(tǒng)創(chuàng)建大量線程而導(dǎo)致消耗完系統(tǒng)內(nèi)存
以下是Java自帶的幾種線程池：
1、newFixedThreadPool 創(chuàng)建一個(gè)指定工作線程數(shù)量的線程池。
每當(dāng)提交一個(gè)任務(wù)就創(chuàng)建一個(gè)工作線程，如果工作線程數(shù)量達(dá)到線程池初始的最大數(shù)，則將提交的任務(wù)存入到池隊(duì)列中。
2、newCachedThreadPool 創(chuàng)建一個(gè)可緩存的線程池。
這種類型的線程池特點(diǎn)是：
1).工作線程的創(chuàng)建數(shù)量幾乎沒有限制(其實(shí)也有限制的,數(shù)目為Interger. MAX_VALUE), 這樣可靈活的往線程池中添加線程。
2).如果長(zhǎng)時(shí)間沒有往線程池中提交任務(wù)，即如果工作線程空閑了指定的時(shí)間(默認(rèn)為1分鐘)，則該工作線程將自動(dòng)終止。終止后，如果你又提交了新的任務(wù)，則線程池重新創(chuàng)建一個(gè)工作線程。
3、newSingleThreadExecutor 創(chuàng)建一個(gè)單線程化的Executor，即只創(chuàng)建唯一的工作者線程來執(zhí)行任務(wù)，如果這個(gè)線程異常結(jié)束，會(huì)有另一個(gè)取代它，保證順序執(zhí)行(我覺得這點(diǎn)是它的特色)。
單工作線程最大的特點(diǎn)是可保證順序地執(zhí)行各個(gè)任務(wù)，并且在任意給定的時(shí)間不會(huì)有多個(gè)線程是活動(dòng)的 。
4、newScheduleThreadPool 創(chuàng)建一個(gè)定長(zhǎng)的線程池，而且支持定時(shí)的以及周期性的任務(wù)執(zhí)行，類似于Timer。
總結(jié)：
一.FixedThreadPool是一個(gè)典型且優(yōu)秀的線程池，它具有線程池提高程序效率和節(jié)省創(chuàng)建線程時(shí)所耗的開銷的優(yōu)點(diǎn)。但在線程池空閑時(shí)，即線程池中沒有可運(yùn)行任務(wù)時(shí)，它不會(huì)釋放工作線程，還會(huì)占用一定的系統(tǒng)資源。
二．CachedThreadPool的特點(diǎn)就是在線程池空閑時(shí)，即線程池中沒有可運(yùn)行任務(wù)時(shí)，它會(huì)釋放工作線程，從而釋放工作線程所占用的資源。但是，但當(dāng)出現(xiàn)新任務(wù)時(shí)，又要?jiǎng)?chuàng)建一新的工作線程，又要一定的系統(tǒng)開銷。并且，在使用CachedThreadPool時(shí)，一定要注意控制任務(wù)的數(shù)量，否則，由于大量線程同時(shí)運(yùn)行，很有會(huì)造成系統(tǒng)癱瘓。
Java線程池 ThreadPoolExecutor使用實(shí)例
package com.sondon.mayi.jpool; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class JPoolLearn { private static int produceTaskSleepTime = 3; private static int produceTaskMaxNumber = 20; public void testThreadPoolExecutor(){ /* * ThreadPoolExecutor( * int corePoolSize, //線程池維護(hù)線程的最少數(shù)量 * int maximumPoolSize, //線程池維護(hù)線程的最大數(shù)量 * long keepAliveTime, //線程池維護(hù)線程所允許的空閑時(shí)間 * TimeUnit unit, //線程池維護(hù)線程所允許的空閑時(shí)間的單位 * BlockingQueue<Runnable> workQueue, //線程池所使用的緩沖隊(duì)列 * RejectedExecutionHandler handler //線程池對(duì)拒絕任務(wù)的處理策略 ) */ ThreadPoolExecutor threadPool = new ThreadPoolExecutor( 5, 10, 3, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10), new ThreadPoolExecutor.DiscardOldestPolicy() ); for (int i = 1; i <= produceTaskMaxNumber; i++) { try { // 產(chǎn)生一個(gè)任務(wù)，并將其加入到線程池 String task = "task---" + i; threadPool.execute(new ThreadPoolTask(task)); System.out.println("activeCount :"+ threadPool.getActiveCount()); // 便于觀察，等待一段時(shí)間 Thread.sleep(produceTaskSleepTime); } catch (Exception e) { e.printStackTrace(); } } //查看當(dāng)前的線程池狀況 while(true){ try { Thread.sleep(3000); System.out.println("pool size :"+threadPool.getPoolSize());//線程池中線程數(shù)量 System.out.println("active count :"+threadPool.getActiveCount());//線程池中活動(dòng)的線程數(shù)量 } catch (InterruptedException e) { e.printStackTrace(); } } } /** * * @Author 蔡文鋒 * @Data_Time 2015年7月25日 下午4:06:28 * @Description { 測(cè)試不同線程池模式 } */ public void testNewCachedThreadPool(){ ThreadPoolExecutor threadPool=(ThreadPoolExecutor) Executors.newCachedThreadPool(); // ThreadPoolExecutor threadPool=(ThreadPoolExecutor) Executors.newFixedThreadPool(100); // ThreadPoolExecutor threadPool=(ThreadPoolExecutor) Executors.newScheduledThreadPool(100); // ThreadPoolExecutor threadPool=(ThreadPoolExecutor) Executors.newSingleThreadExecutor(); try { for (int i = 0; i < 100; i++) { // 產(chǎn)生一個(gè)任務(wù)，并將其加入到線程池 String task = "task---" + i; threadPool.execute(new ThreadPoolTask(task)); System.out.println("activeCount :"); // 便于觀察，等待一段時(shí)間 Thread.sleep(produceTaskSleepTime); } } catch (InterruptedException e) { e.printStackTrace(); } //查看當(dāng)前的線程池狀況 while(true){ try { Thread.sleep(3000); System.out.println("pool size :"+threadPool.getPoolSize());//線程池中線程數(shù)量 System.out.println("active count :"+threadPool.getActiveCount());//線程池中活動(dòng)的線程數(shù)量 } catch (InterruptedException e) { e.printStackTrace(); } } } /** * * @Author 蔡文鋒 * @Data_Time 2015年7月25日 下午4:06:58 * @Description { 測(cè)試callable與runable方法的區(qū)別 } */ public void testNewCachedThreadPool_callable(){ ExecutorService es=Executors.newFixedThreadPool(10); try { // String result=es.submit(new MyCallable<String>()).get(); // System.out.println("callable result :"+result); String result=(String) es.submit(new ThreadPoolTask("")).get(); System.out.println("runable result :"+result); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } } public static void main(String[] args) { new JPoolLearn().testNewCachedThreadPool(); } } /** * 線程池執(zhí)行的任務(wù) */ class ThreadPoolTask implements Runnable { private static int consumeTaskSleepTime = 2000; // 保存任務(wù)所需要的數(shù)據(jù) private Object threadPoolTaskData; ThreadPoolTask(Object tasks) { this.threadPoolTaskData = tasks; } public void run() { System.out.println("start .." + threadPoolTaskData); try { // Sleep 2秒 模擬耗時(shí)操作 Thread.sleep(consumeTaskSleepTime); } catch (Exception e) { e.printStackTrace(); } threadPoolTaskData = null; } public Object getTask() { return this.threadPoolTaskData; } } /** * * @Project : JPool * @Package : com.sondon.mayi.jpool * @Class : MyCallable * @param <T> */ class MyCallable<T> implements Callable<T>{ @Override public T call() throws Exception { System.out.println("開始執(zhí)行Callable"); return (T) "測(cè)試callable接口"; } } 新聞熱點(diǎn)
疑難解答
圖片精選
