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 terminationFurthermore, 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
All Methods Static Methods Instance Methods Concrete Methods 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()
-
-
-
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 classjava.lang.Object
-
-