Package io.aleph.dirigiste

Class Executor

java.lang.Object

java.util.concurrent.AbstractExecutorService

io.aleph.dirigiste.Executor

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService

public class Executor
extends AbstractExecutorService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Executor.Controller

Constructor Summary

Constructors

Constructor	Description
Executor(ThreadFactory threadFactory, BlockingQueue queue, Executor.Controller controller, int initialThreadCount, EnumSet<Stats.Metric> metrics, long samplePeriod, long controlPeriod, TimeUnit unit)

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
void	execute(Runnable runnable)
void	executeWithoutRejection(Runnable runnable)	A version of execute which will simply block until the task is accepted, rather than throwing a RejectedExceptionException.
Stats	getLastStats()
EnumSet<Stats.Metric>	getMetrics()
Stats	getStats()
boolean	isShutdown()
boolean	isTerminated()
void	shutdown()
List<Runnable>	shutdownNow()

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

close

Constructor Details

Executor

public Executor(ThreadFactory threadFactory,
 BlockingQueue queue,
 Executor.Controller controller,
 int initialThreadCount,
 EnumSet<Stats.Metric> metrics,
 long samplePeriod,
 long controlPeriod,
 TimeUnit unit)

Parameters:

threadFactory - the ThreadFactory used by the executor

queue - the queue that holds Runnable objects waiting to be executed

controller - the Controller object that updates the thread count

initialThreadCount - the number of threads that the executor will begin with

metrics - the metrics that will be collected and delivered to the controller

samplePeriod - the period at which the executor's state will be sampled

controlPeriod - the period at which the controller will be invoked with the gathered statistics

unit - the time unit for the #samplePeriod and #controlPeriod

Method Details

getMetrics

public EnumSet<Stats.Metric> getMetrics()

Returns:

the metrics being gathered by the executor

getLastStats

public Stats getLastStats()

Returns:

the last aggregate statistics given to the control loop.

getStats

public Stats getStats()

Returns:

the aggregate statistics for the executor since the last control loop update.

awaitTermination

public boolean awaitTermination(long timeout,
 TimeUnit unit)
                         throws InterruptedException

Throws:

InterruptedException

executeWithoutRejection

public void executeWithoutRejection(Runnable runnable)
                             throws NullPointerException,
InterruptedException

A version of execute which will simply block until the task is accepted, rather than throwing a RejectedExceptionException. RejectedExecutionException will only be thrown if the executor is shut down.

Throws:

NullPointerException

InterruptedException

execute

public void execute(Runnable runnable)
             throws NullPointerException,
RejectedExecutionException

Throws:

NullPointerException

RejectedExecutionException

isShutdown

public boolean isShutdown()

isTerminated

public boolean isTerminated()

shutdown

public void shutdown()

shutdownNow

public List<Runnable> shutdownNow()