com.didiglobal.booster.instrument

Class ShadowThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

com.didiglobal.booster.instrument.ShadowThreadPoolExecutor

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

public class ShadowThreadPoolExecutor
extends java.util.concurrent.ThreadPoolExecutor

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
ShadowThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.RejectedExecutionHandler handler, java.lang.String prefix) Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming
ShadowThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.RejectedExecutionHandler handler, java.lang.String prefix, boolean optimize) Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming
ShadowThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.lang.String prefix) Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming
ShadowThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.lang.String prefix, boolean optimize) Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming
ShadowThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler handler, java.lang.String prefix) Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming
ShadowThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler handler, java.lang.String prefix, boolean optimize) Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming
ShadowThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory threadFactory, java.lang.String prefix) Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming
ShadowThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory threadFactory, java.lang.String prefix, boolean optimize) Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming

Method Summary

Modifier and Type	Method and Description
static java.util.concurrent.ThreadPoolExecutor	newOptimizedThreadPoolExecutor(int corePoolSize, int maxPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue)
static java.util.concurrent.ThreadPoolExecutor	newOptimizedThreadPoolExecutor(int corePoolSize, int maxPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.RejectedExecutionHandler handler)
static java.util.concurrent.ThreadPoolExecutor	newOptimizedThreadPoolExecutor(int corePoolSize, int maxPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.RejectedExecutionHandler handler, java.lang.String name)
static java.util.concurrent.ThreadPoolExecutor	newOptimizedThreadPoolExecutor(int corePoolSize, int maxPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.lang.String name)
static java.util.concurrent.ThreadPoolExecutor	newOptimizedThreadPoolExecutor(int corePoolSize, int maxPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory factory)
static java.util.concurrent.ThreadPoolExecutor	newOptimizedThreadPoolExecutor(int corePoolSize, int maxPoolSize, 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)
static java.util.concurrent.ThreadPoolExecutor	newOptimizedThreadPoolExecutor(int corePoolSize, int maxPoolSize, 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, java.lang.String name)
static java.util.concurrent.ThreadPoolExecutor	newOptimizedThreadPoolExecutor(int corePoolSize, int maxPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory factory, java.lang.String name)
static java.util.concurrent.ThreadPoolExecutor	newThreadPoolExecutor(int corePoolSize, int maxPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.RejectedExecutionHandler handler, java.lang.String name)
static java.util.concurrent.ThreadPoolExecutor	newThreadPoolExecutor(int corePoolSize, int maxPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.lang.String name)
static java.util.concurrent.ThreadPoolExecutor	newThreadPoolExecutor(int corePoolSize, int maxPoolSize, 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, java.lang.String name)
static java.util.concurrent.ThreadPoolExecutor	newThreadPoolExecutor(int corePoolSize, int maxPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory factory, java.lang.String name)

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Detail

ShadowThreadPoolExecutor

public ShadowThreadPoolExecutor(int corePoolSize,
                                int maximumPoolSize,
                                long keepAliveTime,
                                java.util.concurrent.TimeUnit unit,
                                java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                java.lang.String prefix)

Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming

Parameters:

corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set

maximumPoolSize - the maximum number of threads to allow in the pool

keepAliveTime - when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.

unit - the time unit for the keepAliveTime argument

workQueue - the queue to use for holding tasks before they are executed. This queue will hold only the Runnable tasks submitted by the execute method.

prefix - the prefix of new thread

Throws:

java.lang.IllegalArgumentException - if one of the following holds:
corePoolSize < 0
keepAliveTime < 0
maximumPoolSize <= 0
maximumPoolSize < corePoolSize

ShadowThreadPoolExecutor

public ShadowThreadPoolExecutor(int corePoolSize,
                                int maximumPoolSize,
                                long keepAliveTime,
                                java.util.concurrent.TimeUnit unit,
                                java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                java.lang.String prefix,
                                boolean optimize)

Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming

Parameters:

corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set

maximumPoolSize - the maximum number of threads to allow in the pool

keepAliveTime - when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.

unit - the time unit for the keepAliveTime argument

workQueue - the queue to use for holding tasks before they are executed. This queue will hold only the Runnable tasks submitted by the execute method.

prefix - the prefix of new thread

optimize - the value indicates that the thread pool optimization should be applied

Throws:

java.lang.IllegalArgumentException - if one of the following holds:
corePoolSize < 0
keepAliveTime < 0
maximumPoolSize <= 0
maximumPoolSize < corePoolSize

ShadowThreadPoolExecutor

public ShadowThreadPoolExecutor(int corePoolSize,
                                int maximumPoolSize,
                                long keepAliveTime,
                                java.util.concurrent.TimeUnit unit,
                                java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                java.util.concurrent.ThreadFactory threadFactory,
                                java.lang.String prefix)

Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming

Parameters:

corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set

maximumPoolSize - the maximum number of threads to allow in the pool

keepAliveTime - when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.

unit - the time unit for the keepAliveTime argument

workQueue - the queue to use for holding tasks before they are executed. This queue will hold only the Runnable tasks submitted by the execute method.

threadFactory - the factory to use when the executor creates a new thread

prefix - the prefix of new thread

Throws:

java.lang.IllegalArgumentException - if one of the following holds:
corePoolSize < 0
keepAliveTime < 0
maximumPoolSize <= 0
maximumPoolSize < corePoolSize

ShadowThreadPoolExecutor

public ShadowThreadPoolExecutor(int corePoolSize,
                                int maximumPoolSize,
                                long keepAliveTime,
                                java.util.concurrent.TimeUnit unit,
                                java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                java.util.concurrent.ThreadFactory threadFactory,
                                java.lang.String prefix,
                                boolean optimize)

Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming

Parameters:

corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set

maximumPoolSize - the maximum number of threads to allow in the pool

keepAliveTime - when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.

unit - the time unit for the keepAliveTime argument

workQueue - the queue to use for holding tasks before they are executed. This queue will hold only the Runnable tasks submitted by the execute method.

threadFactory - the factory to use when the executor creates a new thread

prefix - the prefix of new thread

optimize - the value indicates that the thread pool optimization should be applied

Throws:

java.lang.IllegalArgumentException - if one of the following holds:
corePoolSize < 0
keepAliveTime < 0
maximumPoolSize <= 0
maximumPoolSize < corePoolSize

ShadowThreadPoolExecutor

public ShadowThreadPoolExecutor(int corePoolSize,
                                int maximumPoolSize,
                                long keepAliveTime,
                                java.util.concurrent.TimeUnit unit,
                                java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                java.util.concurrent.RejectedExecutionHandler handler,
                                java.lang.String prefix)

Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming

Parameters:

corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set

maximumPoolSize - the maximum number of threads to allow in the pool

keepAliveTime - when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.

unit - the time unit for the keepAliveTime argument

workQueue - the queue to use for holding tasks before they are executed. This queue will hold only the Runnable tasks submitted by the execute method.

handler - the handler to use when execution is blocked because the thread bounds and queue capacities are reached

prefix - the prefix of new thread

Throws:

java.lang.IllegalArgumentException - if one of the following holds:
corePoolSize < 0
keepAliveTime < 0
maximumPoolSize <= 0
maximumPoolSize < corePoolSize

ShadowThreadPoolExecutor

public ShadowThreadPoolExecutor(int corePoolSize,
                                int maximumPoolSize,
                                long keepAliveTime,
                                java.util.concurrent.TimeUnit unit,
                                java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                java.util.concurrent.RejectedExecutionHandler handler,
                                java.lang.String prefix,
                                boolean optimize)

Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming

Parameters:

corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set

maximumPoolSize - the maximum number of threads to allow in the pool

keepAliveTime - when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.

unit - the time unit for the keepAliveTime argument

workQueue - the queue to use for holding tasks before they are executed. This queue will hold only the Runnable tasks submitted by the execute method.

handler - the handler to use when execution is blocked because the thread bounds and queue capacities are reached

prefix - the prefix of new thread

optimize - the value indicates that the thread pool optimization should be applied

Throws:

java.lang.IllegalArgumentException - if one of the following holds:
corePoolSize < 0
keepAliveTime < 0
maximumPoolSize <= 0
maximumPoolSize < corePoolSize

ShadowThreadPoolExecutor

public ShadowThreadPoolExecutor(int corePoolSize,
                                int maximumPoolSize,
                                long keepAliveTime,
                                java.util.concurrent.TimeUnit unit,
                                java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                java.util.concurrent.ThreadFactory threadFactory,
                                java.util.concurrent.RejectedExecutionHandler handler,
                                java.lang.String prefix)

Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming

Parameters:

corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set

maximumPoolSize - the maximum number of threads to allow in the pool

keepAliveTime - when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.

unit - the time unit for the keepAliveTime argument

workQueue - the queue to use for holding tasks before they are executed. This queue will hold only the Runnable tasks submitted by the execute method.

threadFactory - the factory to use when the executor creates a new thread

handler - the handler to use when execution is blocked because the thread bounds and queue capacities are reached

prefix - the prefix of new thread

Throws:

java.lang.IllegalArgumentException - if one of the following holds:
corePoolSize < 0
keepAliveTime < 0
maximumPoolSize <= 0
maximumPoolSize < corePoolSize

ShadowThreadPoolExecutor

public ShadowThreadPoolExecutor(int corePoolSize,
                                int maximumPoolSize,
                                long keepAliveTime,
                                java.util.concurrent.TimeUnit unit,
                                java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                java.util.concurrent.ThreadFactory threadFactory,
                                java.util.concurrent.RejectedExecutionHandler handler,
                                java.lang.String prefix,
                                boolean optimize)

Initialize ThreadPoolExecutor with new thread name, this constructor is used by ThreadTransformer for thread renaming

Parameters:

corePoolSize - the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set

maximumPoolSize - the maximum number of threads to allow in the pool

keepAliveTime - when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.

unit - the time unit for the keepAliveTime argument

workQueue - the queue to use for holding tasks before they are executed. This queue will hold only the Runnable tasks submitted by the execute method.

threadFactory - the factory to use when the executor creates a new thread

handler - the handler to use when execution is blocked because the thread bounds and queue capacities are reached

prefix - the prefix of new thread

optimize - the value indicates that the thread pool optimization should be applied

Throws:

java.lang.IllegalArgumentException - if one of the following holds:
corePoolSize < 0
keepAliveTime < 0
maximumPoolSize <= 0
maximumPoolSize < corePoolSize

Method Detail

newThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newThreadPoolExecutor(int corePoolSize,
                                                                            int maxPoolSize,
                                                                            long keepAliveTime,
                                                                            java.util.concurrent.TimeUnit unit,
                                                                            java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                                            java.lang.String name)

newThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newThreadPoolExecutor(int corePoolSize,
                                                                            int maxPoolSize,
                                                                            long keepAliveTime,
                                                                            java.util.concurrent.TimeUnit unit,
                                                                            java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                                            java.util.concurrent.ThreadFactory factory,
                                                                            java.lang.String name)

newThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newThreadPoolExecutor(int corePoolSize,
                                                                            int maxPoolSize,
                                                                            long keepAliveTime,
                                                                            java.util.concurrent.TimeUnit unit,
                                                                            java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                                            java.util.concurrent.RejectedExecutionHandler handler,
                                                                            java.lang.String name)

newThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newThreadPoolExecutor(int corePoolSize,
                                                                            int maxPoolSize,
                                                                            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,
                                                                            java.lang.String name)

newOptimizedThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newOptimizedThreadPoolExecutor(int corePoolSize,
                                                                                     int maxPoolSize,
                                                                                     long keepAliveTime,
                                                                                     java.util.concurrent.TimeUnit unit,
                                                                                     java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue)

newOptimizedThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newOptimizedThreadPoolExecutor(int corePoolSize,
                                                                                     int maxPoolSize,
                                                                                     long keepAliveTime,
                                                                                     java.util.concurrent.TimeUnit unit,
                                                                                     java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                                                     java.util.concurrent.ThreadFactory factory)

newOptimizedThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newOptimizedThreadPoolExecutor(int corePoolSize,
                                                                                     int maxPoolSize,
                                                                                     long keepAliveTime,
                                                                                     java.util.concurrent.TimeUnit unit,
                                                                                     java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                                                     java.util.concurrent.RejectedExecutionHandler handler)

newOptimizedThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newOptimizedThreadPoolExecutor(int corePoolSize,
                                                                                     int maxPoolSize,
                                                                                     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)

newOptimizedThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newOptimizedThreadPoolExecutor(int corePoolSize,
                                                                                     int maxPoolSize,
                                                                                     long keepAliveTime,
                                                                                     java.util.concurrent.TimeUnit unit,
                                                                                     java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                                                     java.lang.String name)

newOptimizedThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newOptimizedThreadPoolExecutor(int corePoolSize,
                                                                                     int maxPoolSize,
                                                                                     long keepAliveTime,
                                                                                     java.util.concurrent.TimeUnit unit,
                                                                                     java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                                                     java.util.concurrent.ThreadFactory factory,
                                                                                     java.lang.String name)

newOptimizedThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newOptimizedThreadPoolExecutor(int corePoolSize,
                                                                                     int maxPoolSize,
                                                                                     long keepAliveTime,
                                                                                     java.util.concurrent.TimeUnit unit,
                                                                                     java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                                                                     java.util.concurrent.RejectedExecutionHandler handler,
                                                                                     java.lang.String name)

newOptimizedThreadPoolExecutor

public static java.util.concurrent.ThreadPoolExecutor newOptimizedThreadPoolExecutor(int corePoolSize,
                                                                                     int maxPoolSize,
                                                                                     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,
                                                                                     java.lang.String name)