public class GroupedThreadPool
extends java.lang.Object
Constructor and Description |
---|
GroupedThreadPool(java.util.concurrent.ThreadPoolExecutor executor) |
Modifier and Type | Method and Description |
---|---|
boolean |
awaitTermination(long timeout,
java.util.concurrent.TimeUnit timeUnit) |
static GroupedThreadPool |
createCachedPool(java.lang.String threadPrefix) |
int |
getActiveCount() |
int |
getLargestPoolSize() |
int |
getQueueSizeForGroup(java.lang.String groupId) |
void |
shutdown() |
void |
shutdownNow() |
java.util.concurrent.Future<?> |
submit(java.lang.String groupId,
java.lang.Runnable runnable) |
public GroupedThreadPool(java.util.concurrent.ThreadPoolExecutor executor)
public static GroupedThreadPool createCachedPool(java.lang.String threadPrefix)
public java.util.concurrent.Future<?> submit(java.lang.String groupId, java.lang.Runnable runnable)
public int getQueueSizeForGroup(java.lang.String groupId)
public int getActiveCount()
public int getLargestPoolSize()
public void shutdown()
public void shutdownNow()
public boolean awaitTermination(long timeout, java.util.concurrent.TimeUnit timeUnit) throws java.lang.InterruptedException
java.lang.InterruptedException