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

An ExecutorService implementation which pins actor to particular threads and guaranteed that an actor's Mailbox will e run on the thread it used it used to run. In situations where we see a lot of cache ping pong, this might lead to significant performance improvements.

INTERNAL API

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