处理内容:线程池工厂类。

备注:

也可以用工具类创建线程池,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;

}

}