什麼原因使我們不得不使用線程池？
個人認為主要原因是：短時間內需要處理的任務數量很多
使用線程池的好處:
1.減少在創建和銷毀線程上所花的時間以及系統資源的開銷
2.如不使用執行緒池，有可能造成系統建立大量執行緒而導致消耗完系統記憶體
以下是Java自帶的幾個執行緒池：
1、newFixedThreadPool 建立一個指定工作執行緒數量的執行緒池。
每當提交一個任務就創建一個工作線程，如果工作線程數量達到線程池初始的最大數，則將提交的任務存入到池隊列中。
2、newCachedThreadPool 建立一個可快取的執行緒池。
這種類型的線程池特點是：
1).工作線程的創建數量幾乎沒有限制(其實也有限制的,數目為Interger. MAX_VALUE), 這樣可靈活的往線程池中添加線程。
2).如果長時間沒有往執行緒池中提交任務，即如果工作執行緒空閒了指定的時間(預設為1分鐘)，則該工作執行緒將自動終止。終止後，如果你又提交了新的任務，則執行緒池重新建立一個工作執行緒。
3、newSingleThreadExecutor 創建一個單線程化的Executor，即只創建唯一的工作者線程來執行任務，如果這個線程異常結束，會有另一個取代它，保證順序執行(我覺得這點是它的特色)。
單工作執行緒最大的特點是可保證順序地執行各個任務，並且在任意給定的時間不會有多個執行緒是活動的 。
4、newScheduleThreadPool 建立一個定長的執行緒池，而且支援定時的以及週期性的任務執行，類似於Timer。
總結：
一.FixedThreadPool是一個典型且優秀的線程池，它具有線程池提高程序效率和節省創建線程時所耗的開銷的優點。但在執行緒池空閒時，也就是當線程池中沒有可運行任務時，它不會釋放工作線程，也會佔用一定的系統資源。
二． CachedThreadPool的特點就是在執行緒池空閒時，也就是當線程池中沒有可執行任務時，它會釋放工作線程，從而釋放工作執行緒所佔用的資源。但是，但當出現新任務時，又要建立一個新的工作線程，又要一定的系統開銷。並且，在使用CachedThreadPool時，請務必注意控制任務的數量，否則，由於大量執行緒同時運行，很有會造成系統癱瘓。
Java線程池 ThreadPoolExecutor使用實例
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, //线程池维护线程的最少数量
* int maximumPoolSize, //线程池维护线程的最大数量
* long keepAliveTime, //线程池维护线程所允许的空闲时间
* TimeUnit unit, //线程池维护线程所允许的空闲时间的单位
* BlockingQueue<Runnable> workQueue, //线程池所使用的缓冲队列
* RejectedExecutionHandler handler //线程池对拒绝任务的处理策略 )
*/
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(
5,
10,
3,
TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(10),
new ThreadPoolExecutor.DiscardOldestPolicy()
);
for (int i = 1; i <= produceTaskMaxNumber; i++) {
try {
// 产生一个任务，并将其加入到线程池
String task = "task---" + i;
threadPool.execute(new ThreadPoolTask(task));
System.out.println("activeCount :"+ threadPool.getActiveCount());
// 便于观察，等待一段时间
Thread.sleep(produceTaskSleepTime);
} catch (Exception e) {
e.printStackTrace();
}
}
//查看当前的线程池状况
while(true){
try {
Thread.sleep(3000);
System.out.println("pool size :"+threadPool.getPoolSize());//线程池中线程数量
System.out.println("active count :"+threadPool.getActiveCount());//线程池中活动的线程数量
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
/**
*
* @Author 蔡文锋
* @Data_Time 2015年7月25日 下午4:06:28
* @Description { 测试不同线程池模式 }
*/
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++) {
// 产生一个任务，并将其加入到线程池
String task = "task---" + i;
threadPool.execute(new ThreadPoolTask(task));
System.out.println("activeCount :");
// 便于观察，等待一段时间
Thread.sleep(produceTaskSleepTime);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
//查看当前的线程池状况
while(true){
try {
Thread.sleep(3000);
System.out.println("pool size :"+threadPool.getPoolSize());//线程池中线程数量
System.out.println("active count :"+threadPool.getActiveCount());//线程池中活动的线程数量
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
/**
*
* @Author 蔡文锋
* @Data_Time 2015年7月25日 下午4:06:58
* @Description { 测试callable与runable方法的区别 }
*/
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();
}
}
/**
* 线程池执行的任务
*/
class ThreadPoolTask implements Runnable {
private static int consumeTaskSleepTime = 2000;
// 保存任务所需要的数据
private Object threadPoolTaskData;
ThreadPoolTask(Object tasks) {
this.threadPoolTaskData = tasks;
}
public void run() {
System.out.println("start .." + threadPoolTaskData);
try {
// Sleep 2秒 模拟耗时操作
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("开始执行Callable");
return (T) "测试callable接口";
}
}登入後複製
更多以實例簡介Java中線程池的工作特點相關文章請關注PHP中文網！
