学步园

在J2SE(TM)5.0 中，增加了线程池的操作，线程池类为 java.util.concurrent.ThreadPoolExecutor

 常用构造方法为：

ThreadPoolExecutor(intcorePoolSize,
                  int maximumPoolSize,
                  long keepAliveTime, TimeUnit unit,
                  BlockingQueue<Runnable> workQueue,
                  RejectedExecutionHandler handler)

参数说明：

任务被添加到线程池中，会出现以下几种情况：

1)       如果此时线程池中的数量小于corePoolSize，即使线程池中的线程都处于空闲状态，也要创建新的线程来处理被添加的任务。

2)       如果此时线程池中的数量等于 corePoolSize，但是缓冲队列 workQueue未满，那么任务被放入缓冲队列。

3)       如果此时线程池中的数量大于corePoolSize，缓冲队列workQueue满，并且线程池中的数量小于maximumPoolSize，建新的线程来处理被添加的任务。

4)       如果此时线程池中的数量大于corePoolSize，缓冲队列workQueue满，并且线程池中的数量等于maximumPoolSize，那么通过 handler所指定的策略来处理此任务。

handler有四个选择：

·       ThreadPoolExecutor.AbortPolicy()
抛出java.util.concurrent.RejectedExecutionException异常

·       ThreadPoolExecutor.CallerRunsPolicy()
重试添加当前的任务，他会自动重复调用execute()方法

·      ThreadPoolExecutor.DiscardOldestPolicy()
抛弃旧的任务

·       ThreadPoolExecutor.DiscardPolicy()
抛弃当前的任务

当线程池中的线程数量大于corePoolSize时，如果某线程空闲时间超过keepAliveTime，线程将被终止。这样，线程池可以动态的调整池中的线程数。

unit可选的参数为java.util.concurrent.TimeUnit中的几个静态属性：
NANOSECONDS、MICROSECONDS、MILLISECONDS、SECONDS。

2、用法举例

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

import com.config.Configuration;
import com.config.ThreadPoolConfiguration;

public class ThreadPool {
	private static ThreadPoolExecutor executor = null;

	static {
		init();
	}

	public static ThreadPoolExecutor getExecutor() {
		if (executor == null) {
			init();
		}

		return executor;
	}
	
	public static void init() {
		ThreadPoolConfiguration config = Configuration.getConfiguration()
		.getPoolConfiguration();
		int corePoolSize = Integer
				.parseInt(config
						.getProperty(ThreadPoolConfiguration.PROPERTY_CORE_POOLSIZE));
		int maxPoolSize = Integer
				.parseInt(config
						.getProperty(ThreadPoolConfiguration.PROPERTY_MAX_POOLSIZE));
		long keepAlive = Integer.parseInt(config
				.getProperty(ThreadPoolConfiguration.PROPERTY_KEEPALIVE));
		executor = new ThreadPoolExecutor(corePoolSize, maxPoolSize,
				keepAlive, TimeUnit.SECONDS,
				new LinkedBlockingQueue(), new ThreadPoolExecutor.CallerRunsPolicy());
	}
}

从配置文件中读取配置初始化ThreadPoolExecutor实例。调用方式：

ThreadPool.getExecutor().execute(new UpdateStatusTask(new StatusBean(messageid, 1)));

UpdateStatusTask是一个实现Runnable接口的类，StatusBean是一个javabean，它在UpdateStatusTask中被使用，可以

是任意类型的类或基本类型

配置文件举例：

<?xml version="1.0" encoding="UTF-8"?>
<java version="1.6.0" class="java.beans.XMLDecoder">
 <object class="com.config.ThreadPoolConfiguration">  
    <!-- 线程池维护线程的最少数量 -->
    <void method="setProperty">
     <string>corePoolSize</string>
     <string>8</string>
    </void>
     <!-- 线程池维护线程的最大数量 -->
    <void method="setProperty">
     <string>maximumPoolSize</string>
     <string>100</string>
    </void>
     <!-- 线程池维护线程所允许的空闲时间(以秒为单位)-->
    <void method="setProperty">
     <string>keepAliveTime</string>
     <string>100</string>
    </void>
 </object>
</java>