org.bluedb.disk.executors

Class GroupedThreadPool

java.lang.Object

org.bluedb.disk.executors.GroupedThreadPool

public class GroupedThreadPool
extends java.lang.Object

Wraps a thread pool that groups tasks based on a group id. Only one task will be allowed to run at a time for each group id.

Constructor Summary

Constructors

Constructor and Description
GroupedThreadPool(java.util.concurrent.ThreadPoolExecutor executor)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupedThreadPool

public GroupedThreadPool(java.util.concurrent.ThreadPoolExecutor executor)

Method Detail

createCachedPool

public static GroupedThreadPool createCachedPool(java.lang.String threadPrefix)

submit

public java.util.concurrent.Future<?> submit(java.lang.String groupId,
                                             java.lang.Runnable runnable)

getQueueSizeForGroup

public int getQueueSizeForGroup(java.lang.String groupId)

getActiveCount

public int getActiveCount()

getLargestPoolSize

public int getLargestPoolSize()

shutdown

public void shutdown()

shutdownNow

public void shutdownNow()

awaitTermination

public boolean awaitTermination(long timeout,
                                java.util.concurrent.TimeUnit timeUnit)
                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException