|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.dispatch.MessageDispatcher akka.testkit.CallingThreadDispatcher
public class CallingThreadDispatcher
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface scala.concurrent.ExecutionContext |
---|
scala.concurrent.ExecutionContext.Implicits$ |
Constructor Summary | |
---|---|
CallingThreadDispatcher(DispatcherPrerequisites _prerequisites,
MailboxType mailboxType,
java.lang.String name)
|
Method Summary | |
---|---|
java.lang.ThreadLocal<scala.collection.immutable.List<java.lang.Runnable>> |
_tasksLocal()
|
boolean |
batchable(java.lang.Runnable runnable)
Override this to define which runnables will be batched. |
protected CallingThreadMailbox |
createMailbox(akka.actor.Cell actor)
|
protected void |
dispatch(akka.actor.ActorCell receiver,
Envelope handle)
Will be called when the dispatcher is to queue an invocation for execution INTERNAL API |
void |
execute(java.lang.Runnable runnable)
|
protected void |
executeTask(TaskInvocation invocation)
INTERNAL API |
java.lang.String |
id()
Identifier of this dispatcher, corresponds to the full key of the dispatcher configuration. |
static java.lang.String |
Id()
|
LoggingAdapter |
log()
|
MailboxType |
mailboxType()
|
java.lang.String |
name()
|
protected void |
register(akka.actor.ActorCell actor)
If you override it, you must call it. |
protected boolean |
registerForExecution(akka.dispatch.Mailbox mbox,
boolean hasMessageHint,
boolean hasSystemMessageHint)
Suggest to register the provided mailbox for execution INTERNAL API |
void |
resume(akka.actor.ActorCell actor)
|
protected void |
shutdown()
Called one time every time an actor is detached from this dispatcher and this dispatcher has no actors left attached Must be idempotent INTERNAL API |
protected scala.concurrent.duration.FiniteDuration |
shutdownTimeout()
When the dispatcher no longer has any actors registered, how long will it wait until it shuts itself down, defaulting to your akka configs "akka.actor.default-dispatcher.shutdown-timeout" or default specified in reference.conf INTERNAL API |
void |
suspend(akka.actor.ActorCell actor)
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference |
protected void |
systemDispatch(akka.actor.ActorCell receiver,
akka.dispatch.SystemMessage message)
Will be called when the dispatcher is to queue an invocation for execution INTERNAL API |
protected int |
throughput()
INTERNAL API |
protected scala.concurrent.duration.FiniteDuration |
throughputDeadlineTime()
INTERNAL API |
Methods inherited from class akka.dispatch.MessageDispatcher |
---|
actors, attach, debug, defaultDispatcher, detach, inhabitants, isThroughputDeadlineTimeDefined, prerequisites, printActors, reportFailure, RESCHEDULED, SCHEDULED, unbatchedExecute, unregister, UNSCHEDULED |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface scala.concurrent.ExecutionContext |
---|
execute, prepare |
Constructor Detail |
---|
public CallingThreadDispatcher(DispatcherPrerequisites _prerequisites, MailboxType mailboxType, java.lang.String name)
Method Detail |
---|
public static java.lang.String Id()
public MailboxType mailboxType()
public java.lang.String name()
public LoggingAdapter log()
public java.lang.String id()
MessageDispatcher
id
in class MessageDispatcher
protected CallingThreadMailbox createMailbox(akka.actor.Cell actor)
protected void shutdown()
MessageDispatcher
INTERNAL API
shutdown
in class MessageDispatcher
protected int throughput()
MessageDispatcher
throughput
in class MessageDispatcher
protected scala.concurrent.duration.FiniteDuration throughputDeadlineTime()
MessageDispatcher
throughputDeadlineTime
in class MessageDispatcher
protected boolean registerForExecution(akka.dispatch.Mailbox mbox, boolean hasMessageHint, boolean hasSystemMessageHint)
MessageDispatcher
INTERNAL API
registerForExecution
in class MessageDispatcher
protected scala.concurrent.duration.FiniteDuration shutdownTimeout()
MessageDispatcher
INTERNAL API
shutdownTimeout
in class MessageDispatcher
protected void register(akka.actor.ActorCell actor)
MessageDispatcher
INTERNAL API
register
in class MessageDispatcher
public void suspend(akka.actor.ActorCell actor)
MessageDispatcher
suspend
in class MessageDispatcher
public void resume(akka.actor.ActorCell actor)
resume
in class MessageDispatcher
protected void systemDispatch(akka.actor.ActorCell receiver, akka.dispatch.SystemMessage message)
MessageDispatcher
INTERNAL API
systemDispatch
in class MessageDispatcher
protected void dispatch(akka.actor.ActorCell receiver, Envelope handle)
MessageDispatcher
INTERNAL API
dispatch
in class MessageDispatcher
protected void executeTask(TaskInvocation invocation)
MessageDispatcher
executeTask
in class MessageDispatcher
public java.lang.ThreadLocal<scala.collection.immutable.List<java.lang.Runnable>> _tasksLocal()
public void execute(java.lang.Runnable runnable)
execute
in interface java.util.concurrent.Executor
public boolean batchable(java.lang.Runnable runnable)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |