com.forte.qqrobot.utils

Class BaseLocalThreadPool

java.lang.Object

com.forte.qqrobot.utils.BaseLocalThreadPool

public abstract class BaseLocalThreadPool
extends Object

用于创建和获取线程池的类，是一个线程池工厂

虽然是个抽象类却没有抽象方法，主要用于继承

可以直接使用set对各种参数进行设置，set的参数为每一次创建线程池的时候使用的配置信息

内部使用map集合实现线程池

Author:

ForteScarlet

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BaseLocalThreadPool.PoolConfig 配置类，提供几个参数

Constructor Summary

Constructors

Constructor and Description
BaseLocalThreadPool()

Method Summary

Modifier and Type	Method and Description
static int	getCorePoolSize()
static ThreadFactory	getFactory() 获取线程工厂
static long	getKeepAliveTime()
static Executor	getLocalThreadPool() 获取本线程中的线程池
static int	getMaximumPoolSize()
static Executor	getThreadPool() 创建线程池的工厂,无名称，使用默认
static Executor	getThreadPool(BaseLocalThreadPool.PoolConfig poolConfig) 创建线程池的工厂,无名称，使用默认
static ExecutorService	getThreadPool(String poolName) 创建线程池的工厂
static Executor	getThreadPool(String poolName, BaseLocalThreadPool.PoolConfig poolConfig) 创建线程池的工厂
static TimeUnit	getTimeUnit()
static BlockingQueue<Runnable>	getWorkQueue()
static boolean	removeLocalThreadPool() Deprecated.
static boolean	removeThreadPool(String poolName) 清除某指定的线程池
static void	setCorePoolSize(int corePoolSize) Deprecated.
static void	setDefaultThreadFactory(ThreadFactory defaultThreadFactory) Deprecated.
static void	setKeepAliveTime(long keepAliveTime) Deprecated.
static void	setMaximumPoolSize(int maximumPoolSize) Deprecated.
static void	setTimeUnit(TimeUnit timeUnit) Deprecated.
static void	setWorkQueue(BlockingQueue<Runnable> workQueue) Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseLocalThreadPool

public BaseLocalThreadPool()

Method Detail

getThreadPool

public static ExecutorService getThreadPool(String poolName)

创建线程池的工厂

Parameters:

poolName - 创建的线程池的名称

Returns:

getThreadPool

public static Executor getThreadPool()

创建线程池的工厂,无名称，使用默认

Returns:

getThreadPool

public static Executor getThreadPool(String poolName,
                                     BaseLocalThreadPool.PoolConfig poolConfig)

创建线程池的工厂

Parameters:

poolName - 创建的线程池的名称

Returns:

getThreadPool

public static Executor getThreadPool(BaseLocalThreadPool.PoolConfig poolConfig)

创建线程池的工厂,无名称，使用默认

Returns:

removeThreadPool

public static boolean removeThreadPool(String poolName)

清除某指定的线程池

Parameters:

poolName -

Returns:

getLocalThreadPool

public static Executor getLocalThreadPool()

获取本线程中的线程池

Returns:

removeLocalThreadPool

@Deprecated
public static boolean removeLocalThreadPool()

Deprecated.

清除本线程中的线程池

getFactory

public static ThreadFactory getFactory()

获取线程工厂

Returns:

getCorePoolSize

public static int getCorePoolSize()

setCorePoolSize

@Deprecated
public static void setCorePoolSize(int corePoolSize)

Deprecated.

getMaximumPoolSize

public static int getMaximumPoolSize()

setMaximumPoolSize

@Deprecated
public static void setMaximumPoolSize(int maximumPoolSize)

Deprecated.

getKeepAliveTime

public static long getKeepAliveTime()

setKeepAliveTime

@Deprecated
public static void setKeepAliveTime(long keepAliveTime)

Deprecated.

getTimeUnit

public static TimeUnit getTimeUnit()

setTimeUnit

@Deprecated
public static void setTimeUnit(TimeUnit timeUnit)

Deprecated.

设置清除时间的类型

Parameters:

timeUnit - 时间类型

getWorkQueue

public static BlockingQueue<Runnable> getWorkQueue()

setWorkQueue

@Deprecated
public static void setWorkQueue(BlockingQueue<Runnable> workQueue)

Deprecated.

设置线程等候阻塞队列

setDefaultThreadFactory

@Deprecated
public static void setDefaultThreadFactory(ThreadFactory defaultThreadFactory)

Deprecated.

设置默认线程工厂

Parameters:

defaultThreadFactory - 线程工厂