akka.dispatch

Class Mailbox

java.lang.Object

java.util.concurrent.ForkJoinTask<scala.runtime.BoxedUnit>

akka.dispatch.Mailbox

All Implemented Interfaces:

SystemMessageQueue, java.io.Serializable, java.lang.Runnable, java.util.concurrent.Future<scala.runtime.BoxedUnit>

Direct Known Subclasses:

CallingThreadMailbox

public abstract class Mailbox
extends java.util.concurrent.ForkJoinTask<scala.runtime.BoxedUnit>
implements SystemMessageQueue, java.lang.Runnable

Mailbox and InternalMailbox is separated in two classes because ActorCell is needed for implementation, but can't be exposed to user defined mailbox subclasses.

INTERNAL API

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Mailbox(MessageQueue messageQueue)

Method Summary

Modifier and Type	Method and Description
protected int	_statusDoNotCallMeDirectly()
protected SystemMessage	_systemQueueDoNotCallMeDirectly()
ActorCell	actor()
boolean	becomeClosed() set new primary status Closed.
boolean	canBeScheduledForExecution(boolean hasMessageHint, boolean hasSystemMessageHint)
static boolean	cancel(boolean x$1)
protected void	cleanUp() Overridable callback to clean up the mailbox, called when an actor is unregistered.
static int	Closed()
static boolean	compareAndSetForkJoinTaskTag(short x$1, short x$2)
static void	complete(V x$1)
static void	completeExceptionally(java.lang.Throwable x$1)
int	currentStatus()
static boolean	debug()
Envelope	dequeue() Try to dequeue the next message from this queue, return null failing that.
MessageDispatcher	dispatcher()
static int	doExec()
void	enqueue(ActorRef receiver, Envelope msg) Try to enqueue the message to this queue, or throw an exception.
boolean	exec()
static java.util.concurrent.ForkJoinTask<V>	fork()
static V	get()
static V	get(long x$1, java.util.concurrent.TimeUnit x$2)
static java.lang.Throwable	getException()
static short	getForkJoinTaskTag()
void	getRawResult()
boolean	hasMessages() Indicates whether this queue is non-empty.
abstract static boolean	hasSystemMessages()
static void	internalPropagateException(java.lang.Throwable x$1)
static void	internalWait(long x$1)
static V	invoke()
static boolean	isCancelled()
boolean	isClosed()
static boolean	isCompletedAbnormally()
static boolean	isCompletedNormally()
static boolean	isDone()
boolean	isScheduled()
boolean	isSuspended()
static V	join()
MessageQueue	messageQueue()
int	numberOfMessages() Should return the current number of messages held in this queue; may always return 0 if no other value is available efficiently.
static int	Open()
void	processAllSystemMessages() Will at least try to process all queued system messages: in case of failure simply drop and go on to the next, because there is nothing to restart here (failure is in ActorCell somewhere …).
static void	quietlyComplete()
static void	quietlyInvoke()
static void	quietlyJoin()
static int	recordExceptionalCompletion(java.lang.Throwable x$1)
static void	reinitialize()
boolean	resume() Reduce the suspend count by one.
void	run()
static int	Scheduled()
void	setActor(ActorCell cell)
boolean	setAsIdle() Reset Scheduled status, keeping primary status as is.
boolean	setAsScheduled() Set Scheduled status, keeping primary status as is.
static short	setForkJoinTaskTag(short x$1)
void	setRawResult(scala.runtime.BoxedUnit unit)
protected void	setStatus(int newStatus)
static int	shouldNotProcessMask()
boolean	shouldProcessMessage()
static int	shouldScheduleMask()
boolean	suspend() Increment the suspend count by one.
int	suspendCount()
static int	suspendMask()
static int	suspendUnit()
abstract static EarliestFirstSystemMessageList	systemDrain(LatestFirstSystemMessageList newContents)
abstract static void	systemEnqueue(ActorRef receiver, SystemMessage message)
protected LatestFirstSystemMessageList	systemQueueGet()
protected boolean	systemQueuePut(LatestFirstSystemMessageList _old, LatestFirstSystemMessageList _new)
static boolean	tryUnfork()
protected boolean	updateStatus(int oldStatus, int newStatus)

Methods inherited from class java.util.concurrent.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.dispatch.SystemMessageQueue

hasSystemMessages, systemDrain, systemEnqueue

Constructor Detail

Mailbox

public Mailbox(MessageQueue messageQueue)

Method Detail

Open

public static final int Open()

Closed

public static final int Closed()

Scheduled

public static final int Scheduled()

shouldScheduleMask

public static final int shouldScheduleMask()

shouldNotProcessMask

public static final int shouldNotProcessMask()

suspendMask

public static final int suspendMask()

suspendUnit

public static final int suspendUnit()

debug

public static final boolean debug()

doExec

public static final int doExec()

internalWait

public static final void internalWait(long x$1)

recordExceptionalCompletion

public static final int recordExceptionalCompletion(java.lang.Throwable x$1)

internalPropagateException

public static void internalPropagateException(java.lang.Throwable x$1)

fork

public static final java.util.concurrent.ForkJoinTask<V> fork()

join

public static final V join()

invoke

public static final V invoke()

cancel

public static boolean cancel(boolean x$1)

isDone

public static final boolean isDone()

isCancelled

public static final boolean isCancelled()

isCompletedAbnormally

public static final boolean isCompletedAbnormally()

isCompletedNormally

public static final boolean isCompletedNormally()

getException

public static final java.lang.Throwable getException()

completeExceptionally

public static void completeExceptionally(java.lang.Throwable x$1)

complete

public static void complete(V x$1)

quietlyComplete

public static final void quietlyComplete()

get

public static final V get()
                   throws java.util.concurrent.ExecutionException,
                          java.lang.InterruptedException

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException

get

public static final V get(long x$1,
                          java.util.concurrent.TimeUnit x$2)
                   throws java.util.concurrent.TimeoutException,
                          java.util.concurrent.ExecutionException,
                          java.lang.InterruptedException

Throws:

java.util.concurrent.TimeoutException

java.util.concurrent.ExecutionException

java.lang.InterruptedException

quietlyJoin

public static final void quietlyJoin()

quietlyInvoke

public static final void quietlyInvoke()

reinitialize

public static void reinitialize()

tryUnfork

public static boolean tryUnfork()

getForkJoinTaskTag

public static final short getForkJoinTaskTag()

setForkJoinTaskTag

public static final short setForkJoinTaskTag(short x$1)

compareAndSetForkJoinTaskTag

public static final boolean compareAndSetForkJoinTaskTag(short x$1,
                                                         short x$2)

systemEnqueue

public abstract static void systemEnqueue(ActorRef receiver,
                                          SystemMessage message)

systemDrain

public abstract static EarliestFirstSystemMessageList systemDrain(LatestFirstSystemMessageList newContents)

hasSystemMessages

public abstract static boolean hasSystemMessages()

messageQueue

public MessageQueue messageQueue()

actor

public ActorCell actor()

setActor

public void setActor(ActorCell cell)

dispatcher

public MessageDispatcher dispatcher()

enqueue

public void enqueue(ActorRef receiver,
                    Envelope msg)

Try to enqueue the message to this queue, or throw an exception.

Parameters:

receiver - (undocumented)

msg - (undocumented)

dequeue

public Envelope dequeue()

Try to dequeue the next message from this queue, return null failing that.

Returns:

(undocumented)

hasMessages

public boolean hasMessages()

Indicates whether this queue is non-empty.

Returns:

(undocumented)

numberOfMessages

public int numberOfMessages()

Should return the current number of messages held in this queue; may always return 0 if no other value is available efficiently. Do not use this for testing for presence of messages, use hasMessages instead.

Returns:

(undocumented)

_statusDoNotCallMeDirectly

protected int _statusDoNotCallMeDirectly()

_systemQueueDoNotCallMeDirectly

protected SystemMessage _systemQueueDoNotCallMeDirectly()

currentStatus

public final int currentStatus()

shouldProcessMessage

public final boolean shouldProcessMessage()

suspendCount

public final int suspendCount()

isSuspended

public final boolean isSuspended()

isClosed

public final boolean isClosed()

isScheduled

public final boolean isScheduled()

updateStatus

protected final boolean updateStatus(int oldStatus,
                                     int newStatus)

setStatus

protected final void setStatus(int newStatus)

resume

public final boolean resume()

Reduce the suspend count by one. Caller does not need to worry about whether status was Scheduled or not.

Returns:

true if the suspend count reached zero

suspend

public final boolean suspend()

Increment the suspend count by one. Caller does not need to worry about whether status was Scheduled or not.

Returns:

true if the previous suspend count was zero

becomeClosed

public final boolean becomeClosed()

set new primary status Closed. Caller does not need to worry about whether status was Scheduled or not.

Returns:

(undocumented)

setAsScheduled

public final boolean setAsScheduled()

Set Scheduled status, keeping primary status as is.

Returns:

(undocumented)

setAsIdle

public final boolean setAsIdle()

Reset Scheduled status, keeping primary status as is.

Returns:

(undocumented)

systemQueueGet

protected final LatestFirstSystemMessageList systemQueueGet()

systemQueuePut

protected final boolean systemQueuePut(LatestFirstSystemMessageList _old,
                                       LatestFirstSystemMessageList _new)

canBeScheduledForExecution

public final boolean canBeScheduledForExecution(boolean hasMessageHint,
                                                boolean hasSystemMessageHint)

run

public final void run()

Specified by:

run in interface java.lang.Runnable

getRawResult

public final void getRawResult()

setRawResult

public final void setRawResult(scala.runtime.BoxedUnit unit)

Specified by:

setRawResult in class java.util.concurrent.ForkJoinTask<scala.runtime.BoxedUnit>

exec

public final boolean exec()

Specified by:

exec in class java.util.concurrent.ForkJoinTask<scala.runtime.BoxedUnit>

processAllSystemMessages

public final void processAllSystemMessages()

Will at least try to process all queued system messages: in case of failure simply drop and go on to the next, because there is nothing to restart here (failure is in ActorCell somewhere …). In case the mailbox becomes closed (because of processing a Terminate message), dump all already dequeued message to deadLetters.

cleanUp

protected void cleanUp()

Overridable callback to clean up the mailbox, called when an actor is unregistered. By default it dequeues all system messages + messages and ships them to the owning actors' systems' DeadLetterMailbox