Package akka.dispatch.affinity

Class AffinityPool

java.lang.Object

java.util.concurrent.AbstractExecutorService

akka.dispatch.affinity.AffinityPool

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

public class AffinityPool
extends java.util.concurrent.AbstractExecutorService

Each worker should go through that method while terminating. In turn each worker is responsible for modifying the pool state accordingly. For example if this is the last worker and the queue is empty and we are in a ShuttingDown state the worker can transition the pool to ShutDown and attempt termination

Furthermore, if this worker has experienced abrupt termination due to an exception being thrown in user code, the worker is responsible for adding one more worker to compensate for its own termination

Constructor Summary

Constructors

Constructor	Description
AffinityPool(java.lang.String id, int parallelism, int affinityGroupSize, java.util.concurrent.ThreadFactory threadFactory, int idleCpuLevel, QueueSelector queueSelector, RejectionHandler rejectionHandler)

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
void	execute(java.lang.Runnable command)
static int	Initial()
static int	Initializing()
boolean	isShutdown()
boolean	isTerminated()
static int	Parking()
QueueSelector	queueSelector()
static int	Running()
void	shutdown()
static int	ShutDown()
java.util.List<java.lang.Runnable>	shutdownNow()
static int	ShuttingDown()
static int	Spinning()
AffinityPool	start()
static int	Terminated()
java.lang.String	toString()
static int	Uninitialized()
static int	Yielding()

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, wait, wait, wait

Constructor Detail

AffinityPool

public AffinityPool(java.lang.String id,
                    int parallelism,
                    int affinityGroupSize,
                    java.util.concurrent.ThreadFactory threadFactory,
                    int idleCpuLevel,
                    QueueSelector queueSelector,
                    RejectionHandler rejectionHandler)

Method Detail

Uninitialized

public static final int Uninitialized()

Initializing

public static final int Initializing()

Running

public static final int Running()

ShuttingDown

public static final int ShuttingDown()

ShutDown

public static final int ShutDown()

Terminated

public static final int Terminated()

Initial

public static final int Initial()

Spinning

public static final int Spinning()

Yielding

public static final int Yielding()

Parking

public static final int Parking()

queueSelector

public final QueueSelector queueSelector()

start

public AffinityPool start()

execute

public void execute(java.lang.Runnable command)

awaitTermination

public boolean awaitTermination(long timeout,
                                java.util.concurrent.TimeUnit unit)

shutdownNow

public java.util.List<java.lang.Runnable> shutdownNow()

shutdown

public void shutdown()

isShutdown

public boolean isShutdown()

isTerminated

public boolean isTerminated()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object