public final class ConcurrentEnvironment
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
java.lang.Runnable |
executeStandaloneTask(java.lang.Runnable r) |
static ConcurrentEnvironment |
getInstance() |
BoundedExecutor |
newBoundedExecutor(java.lang.String name,
int concurrencyLevel,
int maxQueueCapacity) |
java.util.concurrent.ThreadPoolExecutor |
newFixedThreadPool(java.lang.String name,
int size) |
java.util.concurrent.ThreadPoolExecutor |
newFixedThreadPool(java.lang.String name,
int size,
boolean daemon) |
HashExecutor |
newHashExecutor(java.lang.String name,
int concurrencyLevel) |
java.util.concurrent.ScheduledThreadPoolExecutor |
newScheduledThreadPool(java.lang.String name,
int corePoolSize) |
java.util.concurrent.ScheduledThreadPoolExecutor |
newScheduledThreadPool(java.lang.String name,
int corePoolSize,
boolean daemon) |
java.util.concurrent.ThreadPoolExecutor |
newThreadPool(java.lang.String name,
int corePoolSize) |
java.util.concurrent.ThreadPoolExecutor |
newThreadPool(java.lang.String name,
int corePoolSize,
boolean daemon) |
TimeoutExecutor |
newTimeoutExecutor(java.lang.String name,
long timeout,
java.util.concurrent.TimeUnit unit) |
void |
setCorePoolSize(java.lang.String name,
int corePoolSize) |
void |
shutdown() |
void |
shutdown(java.lang.String... names) |
public static ConcurrentEnvironment getInstance()
public void setCorePoolSize(java.lang.String name, int corePoolSize)
public java.util.concurrent.ThreadPoolExecutor newThreadPool(java.lang.String name, int corePoolSize, boolean daemon)
public java.util.concurrent.ThreadPoolExecutor newThreadPool(java.lang.String name, int corePoolSize)
public java.util.concurrent.ThreadPoolExecutor newFixedThreadPool(java.lang.String name, int size, boolean daemon)
public java.util.concurrent.ThreadPoolExecutor newFixedThreadPool(java.lang.String name, int size)
public java.util.concurrent.ScheduledThreadPoolExecutor newScheduledThreadPool(java.lang.String name, int corePoolSize, boolean daemon)
public java.util.concurrent.ScheduledThreadPoolExecutor newScheduledThreadPool(java.lang.String name, int corePoolSize)
public TimeoutExecutor newTimeoutExecutor(java.lang.String name, long timeout, java.util.concurrent.TimeUnit unit)
public HashExecutor newHashExecutor(java.lang.String name, int concurrencyLevel)
public BoundedExecutor newBoundedExecutor(java.lang.String name, int concurrencyLevel, int maxQueueCapacity)
public void shutdown(java.lang.String... names)
public void shutdown()
public java.lang.Runnable executeStandaloneTask(java.lang.Runnable r)