public class BlueExecutor
extends java.lang.Object
Constructor and Description |
---|
BlueExecutor(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
boolean |
awaitTermination(long timeout,
java.util.concurrent.TimeUnit timeUnit) |
int |
getQueryQueueSize(java.lang.String collectionName) |
void |
scheduleTaskAtFixedRate(java.lang.Runnable task,
long initialDelay,
long period,
java.util.concurrent.TimeUnit timeUnit) |
void |
shutdown() |
void |
shutdownNow() |
java.util.concurrent.Future<?> |
submitQueryTask(java.lang.String collectionName,
java.lang.Runnable task) |
public java.util.concurrent.Future<?> submitQueryTask(java.lang.String collectionName, java.lang.Runnable task)
public int getQueryQueueSize(java.lang.String collectionName)
public void scheduleTaskAtFixedRate(java.lang.Runnable task, long initialDelay, long period, java.util.concurrent.TimeUnit timeUnit)
public void shutdown()
public void shutdownNow()
public boolean awaitTermination(long timeout, java.util.concurrent.TimeUnit timeUnit) throws java.lang.InterruptedException
java.lang.InterruptedException