org.bluedb.disk.executors

Class BlueExecutor

java.lang.Object

org.bluedb.disk.executors.BlueExecutor

public class BlueExecutor
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
BlueExecutor(java.lang.String name)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

BlueExecutor

public BlueExecutor(java.lang.String name)

Method Detail

submitQueryTask

public java.util.concurrent.Future<?> submitQueryTask(java.lang.String collectionName,
                                                      java.lang.Runnable task)

getQueryQueueSize

public int getQueryQueueSize(java.lang.String collectionName)

scheduleTaskAtFixedRate

public void scheduleTaskAtFixedRate(java.lang.Runnable task,
                                    long initialDelay,
                                    long period,
                                    java.util.concurrent.TimeUnit timeUnit)

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