org.voovan.tools.threadpool

Class ThreadPool

java.lang.Object

org.voovan.tools.threadpool.ThreadPool

public class ThreadPool
extends Object

线程池

Author:

helyho Voovan Framework. WebSite: https://github.com/helyho/Voovan Licence: Apache v2 License

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	MAX_POOL_SIZE
protected static int	maxPoolSize
protected static int	MIN_POOL_SIZE
protected static int	minPoolSize
protected static int	STATUS_INTERVAL
protected static ConcurrentHashMap<String,ThreadPoolExecutor>	THREAD_POOL_HANDLER

Method Summary

Modifier and Type	Method and Description
static ThreadPoolExecutor	createThreadPool(String poolName) 使用默认配置构造线程池, 配置来自于 fraemwork.properties
static ThreadPoolExecutor	createThreadPool(String poolName, int mimPoolSize, int maxPoolSize, int keepAliveTime) 创建线程池
static ThreadPoolExecutor	createThreadPool(String poolName, int mimPoolSize, int maxPoolSize, int keepAliveTime, boolean daemon, int priority) 创建线程池
static ThreadPoolExecutor	createThreadPool(String poolName, int mimPoolSize, int maxPoolSize, int keepAliveTime, boolean daemon, int priority, int queueSize) 创建线程池
static int	getMaxPoolSize() 获取线程池最大活动线程数
static int	getMinPoolSize() 获取线程池最小活动线程数
static int	getStatusInterval() 获取线程池最大活动线程数
static void	gracefulShutdown(ThreadPoolExecutor threadPoolExecutor) 平滑的关闭线程池

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MIN_POOL_SIZE

protected static int MIN_POOL_SIZE

MAX_POOL_SIZE

protected static int MAX_POOL_SIZE

STATUS_INTERVAL

protected static int STATUS_INTERVAL

minPoolSize

protected static int minPoolSize

maxPoolSize

protected static int maxPoolSize

THREAD_POOL_HANDLER

protected static ConcurrentHashMap<String,ThreadPoolExecutor> THREAD_POOL_HANDLER

Method Detail

getMinPoolSize

public static int getMinPoolSize()

获取线程池最小活动线程数

Returns:

线程池最小活动线程数

getMaxPoolSize

public static int getMaxPoolSize()

获取线程池最大活动线程数

Returns:

线程池最大活动线程数

getStatusInterval

public static int getStatusInterval()

获取线程池最大活动线程数

Returns:

线程池最大活动线程数

createThreadPool

public static ThreadPoolExecutor createThreadPool(String poolName)

使用默认配置构造线程池, 配置来自于 fraemwork.properties

Parameters:

poolName - 线程池名称

Returns:

线程池对象

createThreadPool

public static ThreadPoolExecutor createThreadPool(String poolName,
                                                  int mimPoolSize,
                                                  int maxPoolSize,
                                                  int keepAliveTime)

创建线程池

Parameters:

poolName - 池的名称

mimPoolSize - 最小线程数

maxPoolSize - 最大线程数

keepAliveTime - 线程闲置最大存活时间,单位: 毫秒

Returns:

线程池对象

createThreadPool

public static ThreadPoolExecutor createThreadPool(String poolName,
                                                  int mimPoolSize,
                                                  int maxPoolSize,
                                                  int keepAliveTime,
                                                  boolean daemon,
                                                  int priority)

创建线程池

Parameters:

poolName - 池的名称

mimPoolSize - 最小线程数

maxPoolSize - 最大线程数

keepAliveTime - 线程闲置最大存活时间, 单位: 毫秒

daemon - 是否是守护线程

priority - 线程优先级

Returns:

线程池对象

createThreadPool

public static ThreadPoolExecutor createThreadPool(String poolName,
                                                  int mimPoolSize,
                                                  int maxPoolSize,
                                                  int keepAliveTime,
                                                  boolean daemon,
                                                  int priority,
                                                  int queueSize)

创建线程池

Parameters:

poolName - 池的名称

mimPoolSize - 最小线程数

maxPoolSize - 最大线程数

keepAliveTime - 线程闲置最大存活时间, 单位: 毫秒

daemon - 是否是守护线程

priority - 线程优先级

queueSize - 线程池任务队列大小

Returns:

线程池对象

gracefulShutdown

public static void gracefulShutdown(ThreadPoolExecutor threadPoolExecutor)

平滑的关闭线程池

Parameters:

threadPoolExecutor - 线程池对象