public class ThreadPoolConfig extends java.lang.Object implements ExecutorServiceFactoryProvider, scala.Product, scala.Serializable
Modifier and Type | Class and Description |
---|---|
class |
ThreadPoolConfig.ThreadPoolExecutorServiceFactory |
Constructor and Description |
---|
ThreadPoolConfig(boolean allowCorePoolTimeout,
int corePoolSize,
int maxPoolSize,
scala.concurrent.duration.Duration threadTimeout,
scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory,
java.util.concurrent.RejectedExecutionHandler rejectionPolicy) |
Modifier and Type | Method and Description |
---|---|
boolean |
allowCorePoolTimeout() |
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> |
arrayBlockingQueue(int capacity,
boolean fair) |
int |
corePoolSize() |
ExecutorServiceFactory |
createExecutorServiceFactory(java.lang.String id,
java.util.concurrent.ThreadFactory threadFactory) |
static boolean |
defaultAllowCoreThreadTimeout() |
static int |
defaultCorePoolSize() |
static int |
defaultMaxPoolSize() |
static java.util.concurrent.RejectedExecutionHandler |
defaultRejectionPolicy() |
static scala.concurrent.duration.Duration |
defaultTimeout() |
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> |
linkedBlockingQueue() |
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> |
linkedBlockingQueue(int capacity) |
int |
maxPoolSize() |
scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> |
queueFactory() |
java.util.concurrent.RejectedExecutionHandler |
rejectionPolicy() |
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> |
reusableQueue(java.util.concurrent.BlockingQueue<java.lang.Runnable> queue) |
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> |
reusableQueue(scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory) |
static int |
scaledPoolSize(int floor,
double multiplier,
int ceiling) |
static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> |
synchronousQueue(boolean fair) |
scala.concurrent.duration.Duration |
threadTimeout() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ThreadPoolConfig(boolean allowCorePoolTimeout, int corePoolSize, int maxPoolSize, scala.concurrent.duration.Duration threadTimeout, scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory, java.util.concurrent.RejectedExecutionHandler rejectionPolicy)
public static boolean defaultAllowCoreThreadTimeout()
public static int defaultCorePoolSize()
public static int defaultMaxPoolSize()
public static scala.concurrent.duration.Duration defaultTimeout()
public static java.util.concurrent.RejectedExecutionHandler defaultRejectionPolicy()
public static int scaledPoolSize(int floor, double multiplier, int ceiling)
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> arrayBlockingQueue(int capacity, boolean fair)
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> synchronousQueue(boolean fair)
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> linkedBlockingQueue()
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> linkedBlockingQueue(int capacity)
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> reusableQueue(java.util.concurrent.BlockingQueue<java.lang.Runnable> queue)
public static scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> reusableQueue(scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory)
public boolean allowCorePoolTimeout()
public int corePoolSize()
public int maxPoolSize()
public scala.concurrent.duration.Duration threadTimeout()
public scala.Function0<java.util.concurrent.BlockingQueue<java.lang.Runnable>> queueFactory()
public java.util.concurrent.RejectedExecutionHandler rejectionPolicy()
public final ExecutorServiceFactory createExecutorServiceFactory(java.lang.String id, java.util.concurrent.ThreadFactory threadFactory)
createExecutorServiceFactory
in interface ExecutorServiceFactoryProvider