com.graphdbapi.concurrent

Class ThreadPoolFactory

java.lang.Object

com.graphdbapi.concurrent.ThreadPoolFactory

public class ThreadPoolFactory
extends java.lang.Object

线程池工厂 用于创建线程池(使用此类创建的线程池可用监控)

Constructor Summary

Constructors

Constructor and Description
ThreadPoolFactory()

Method Summary

Modifier and Type	Method and Description
static java.util.concurrent.ExecutorService	create(java.lang.String poolName, int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, boolean enableTaskMonitor) 创建线程
static java.util.concurrent.ExecutorService	create(java.lang.String poolName, int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.RejectedExecutionHandler handler, boolean enableTaskMonitor) 创建线程
static java.util.concurrent.ExecutorService	create(java.lang.String poolName, int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory factory, java.util.concurrent.RejectedExecutionHandler handler, boolean enableTaskMonitor) 创建线程
static java.util.concurrent.ExecutorService	getOrCreate(java.lang.String poolName, int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, boolean enableTaskMonitor) 获取或创建线程
static java.util.concurrent.ExecutorService	getOrCreate(java.lang.String poolName, int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.RejectedExecutionHandler handler, boolean enableTaskMonitor) 获取或创建线程
static java.util.concurrent.ExecutorService	getOrCreate(java.lang.String poolName, int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory factory, java.util.concurrent.RejectedExecutionHandler handler, boolean enableTaskMonitor) 获取或创建线程

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPoolFactory

public ThreadPoolFactory()

Method Detail

create

public static java.util.concurrent.ExecutorService create(java.lang.String poolName,
                                                          int corePoolSize,
                                                          int maximumPoolSize,
                                                          long keepAliveTime,
                                                          java.util.concurrent.TimeUnit unit,
                                                          java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                          boolean enableTaskMonitor)

创建线程

Parameters:

poolName - 线程池名称

corePoolSize - 核心线程数

maximumPoolSize - 最大线程数

keepAliveTime - 活跃时间

unit - 活跃时间单位

workQueue - 任务队列

enableTaskMonitor - 是否开启监控（用于监控线程池内各项指标）

Returns:

ExecutorService

create

public static java.util.concurrent.ExecutorService create(java.lang.String poolName,
                                                          int corePoolSize,
                                                          int maximumPoolSize,
                                                          long keepAliveTime,
                                                          java.util.concurrent.TimeUnit unit,
                                                          java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                          java.util.concurrent.RejectedExecutionHandler handler,
                                                          boolean enableTaskMonitor)

创建线程

Parameters:

poolName - 线程池名称

corePoolSize - 核心线程数

maximumPoolSize - 最大线程数

keepAliveTime - 活跃时间

unit - 活跃时间单位

workQueue - 任务队列

handler - 被拒绝执行处理器

enableTaskMonitor - 是否开启监控（用于监控线程池内各项指标）

Returns:

ExecutorService

create

public static java.util.concurrent.ExecutorService create(java.lang.String poolName,
                                                          int corePoolSize,
                                                          int maximumPoolSize,
                                                          long keepAliveTime,
                                                          java.util.concurrent.TimeUnit unit,
                                                          java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                          java.util.concurrent.ThreadFactory factory,
                                                          java.util.concurrent.RejectedExecutionHandler handler,
                                                          boolean enableTaskMonitor)

创建线程

Parameters:

poolName - 线程池名称

corePoolSize - 核心线程数

maximumPoolSize - 最大线程数

keepAliveTime - 活跃时间

unit - 活跃时间单位

workQueue - 任务队列

factory - 线程工厂

handler - 被拒绝执行处理器

enableTaskMonitor - 是否开启监控（用于监控线程池内各项指标）

Returns:

ExecutorService

getOrCreate

public static java.util.concurrent.ExecutorService getOrCreate(java.lang.String poolName,
                                                               int corePoolSize,
                                                               int maximumPoolSize,
                                                               long keepAliveTime,
                                                               java.util.concurrent.TimeUnit unit,
                                                               java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                               boolean enableTaskMonitor)

获取或创建线程

Parameters:

poolName - 线程池名称

corePoolSize - 核心线程数

maximumPoolSize - 最大线程数

keepAliveTime - 活跃时间

unit - 活跃时间单位

workQueue - 任务队列

enableTaskMonitor - 是否开启监控（用于监控线程池内各项指标）

Returns:

ExecutorService

getOrCreate

public static java.util.concurrent.ExecutorService getOrCreate(java.lang.String poolName,
                                                               int corePoolSize,
                                                               int maximumPoolSize,
                                                               long keepAliveTime,
                                                               java.util.concurrent.TimeUnit unit,
                                                               java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                               java.util.concurrent.RejectedExecutionHandler handler,
                                                               boolean enableTaskMonitor)

获取或创建线程

Parameters:

poolName - 线程池名称

corePoolSize - 核心线程数

maximumPoolSize - 最大线程数

keepAliveTime - 活跃时间

unit - 活跃时间单位

workQueue - 任务队列

handler - 被拒绝执行处理器

enableTaskMonitor - 是否开启监控（用于监控线程池内各项指标）

Returns:

ExecutorService

getOrCreate

public static java.util.concurrent.ExecutorService getOrCreate(java.lang.String poolName,
                                                               int corePoolSize,
                                                               int maximumPoolSize,
                                                               long keepAliveTime,
                                                               java.util.concurrent.TimeUnit unit,
                                                               java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                               java.util.concurrent.ThreadFactory factory,
                                                               java.util.concurrent.RejectedExecutionHandler handler,
                                                               boolean enableTaskMonitor)

获取或创建线程

Parameters:

poolName - 线程池名称

corePoolSize - 核心线程数

maximumPoolSize - 最大线程数

keepAliveTime - 活跃时间

unit - 活跃时间单位

workQueue - 任务队列

factory - 线程工厂

handler - 被拒绝执行处理器

enableTaskMonitor - 是否开启监控（用于监控线程池内各项指标）

Returns:

ExecutorService