处理内容:线程池工厂类。
备注:
也可以用工具类创建线程池,Excutors来创建,因为Excutors创建线程池也是底层用的也是
ThreadPoolExecutor,所有就干脆用这个了,顺便了解一下。
newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。
newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。
newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行。
newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。
注意,本工具类使用的队列是LinkedBlockingQueue,这个队列是×××队列,就是没有指定容量,可以无限大。因此这个参数就是无效的maximumPoolSize。为什么会采用这种,因为我现在工作线程的处理速度比放入工作线程的任务快。
(corePoolSize, maximumPoolSize, keepAliveTime)参数意义,可以自己去找,网上一大堆,不再陈述。
开发过程中,用线程池可以减少创建和销毁线程的开销。直接上代码把。
/**
* 处理内容:线程池工厂类
*
* @author shangdc
*
*/
@Component("multiThreadPoolExecutorFactory")
public class MultiThreadPoolExecutorFactory {
/**
* corePoolSize 池中所保存的线程数,包括空闲线程。
*/
private static final int corePoolSize = 50;
/**
* maximumPoolSize - 池中允许的最大线程数(采用LinkedBlockingQueue时没有作用)。
*/
private static final int maximumPoolSize = 100;
/**
* keepAliveTime -当线程数大于核心时,此为终止前多余的空闲线程等待新任务的最长时间,线程池维护线程所允许的空闲时间
*/
private static final int keepAliveTime = 60;
/**
* 执行前用于保持任务的队列(缓冲队列)
*/
private static final int capacity = 300;
/**
* 线程池对象
*/
private static ThreadPoolExecutor threadPoolExecutor = null;
// 构造方法私有化
private MultiThreadPoolExecutorFactory() {
}
public static ThreadPoolExecutor getThreadPoolExecutor() {
if (null == threadPoolExecutor) {
ThreadPoolExecutor t;
synchronized (ThreadPoolExecutor.class) {
t = threadPoolExecutor;
if (null == t) {
synchronized (ThreadPoolExecutor.class) {
t = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>(), new ThreadPoolExecutor.CallerRunsPolicy());
}
threadPoolExecutor = t;
}
}
}
return threadPoolExecutor;
}
}