class PinnedDispatcher extends Dispatcher
Dedicates a unique thread for each actor passed in as reference. Served through its messageQueue.
The preferred way of creating dispatchers is to define configuration of it and use the
the lookup method in akka.dispatch.Dispatchers.
- Source
- PinnedDispatcher.scala
Linear Supertypes
Dispatcher, MessageDispatcher, ExecutionContextExecutor, ExecutionContext, BatchingExecutor, Executor, AbstractMessageDispatcher, AnyRef, Any
Type Hierarchy
Ordering
- Alphabetic
- By Inheritance
Inherited
- PinnedDispatcher
- Dispatcher
- MessageDispatcher
- ExecutionContextExecutor
- ExecutionContext
- BatchingExecutor
- Executor
- AbstractMessageDispatcher
- AnyRef
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new PinnedDispatcher(_configurator: MessageDispatcherConfigurator, _actor: ActorCell, _id: String, _shutdownTimeout: FiniteDuration, _threadPoolConfig: ThreadPoolConfig)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to any2stringadd[PinnedDispatcher] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (PinnedDispatcher, B)
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to ArrowAssoc[PinnedDispatcher] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
final
def
attach(actor: ActorCell): Unit
Attaches the specified actor instance to this dispatcher, which includes scheduling it to run for the first time (Create() is expected to have been enqueued by the ActorCell upon mailbox creation).
Attaches the specified actor instance to this dispatcher, which includes scheduling it to run for the first time (Create() is expected to have been enqueued by the ActorCell upon mailbox creation).
- Definition Classes
- MessageDispatcher
-
def
batchable(runnable: Runnable): Boolean
Override this to define which runnables will be batched.
Override this to define which runnables will be batched.
- Definition Classes
- BatchingExecutor
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
val
configurator: MessageDispatcherConfigurator
- Definition Classes
- MessageDispatcher
-
def
createMailbox(actor: Cell, mailboxType: MailboxType): Mailbox
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
final
def
detach(actor: ActorCell): Unit
Detaches the specified actor instance from this dispatcher
Detaches the specified actor instance from this dispatcher
- Definition Classes
- MessageDispatcher
-
def
dispatch(receiver: ActorCell, invocation: Envelope): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
def
ensuring(cond: (PinnedDispatcher) ⇒ Boolean, msg: ⇒ Any): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (PinnedDispatcher) ⇒ Boolean): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
val
eventStream: EventStream
- Definition Classes
- MessageDispatcher
-
def
execute(runnable: Runnable): Unit
- Definition Classes
- BatchingExecutor → Executor
-
def
executeTask(invocation: TaskInvocation): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
final
def
executorService: ExecutorServiceDelegate
- Attributes
- protected
- Definition Classes
- Dispatcher
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to StringFormat[PinnedDispatcher] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
val
id: String
- Definition Classes
- Dispatcher → MessageDispatcher
-
final
def
inhabitants: Long
- Definition Classes
- MessageDispatcher
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
val
isThroughputDeadlineTimeDefined: Boolean
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- MessageDispatcher
-
val
mailboxes: Mailboxes
- Definition Classes
- MessageDispatcher
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
def
register(actorCell: ActorCell): Unit
If you override it, you must call it.
If you override it, you must call it. But only ever once. See "attach" for only invocation.
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- PinnedDispatcher → MessageDispatcher
-
def
registerForExecution(mbox: Mailbox, hasMessageHint: Boolean, hasSystemMessageHint: Boolean): Boolean
Returns if it was registered
Returns if it was registered
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
def
reportFailure(t: Throwable): Unit
- Definition Classes
- MessageDispatcher → ExecutionContext
-
final
def
resubmitOnBlock: Boolean
- Attributes
- protected
- Definition Classes
- MessageDispatcher → BatchingExecutor
-
def
resume(actor: ActorCell): Unit
- Attributes
- protected[akka]
- Definition Classes
- MessageDispatcher
-
def
shutdown(): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
shutdownTimeout: FiniteDuration
- Definition Classes
- Dispatcher → MessageDispatcher
-
def
suspend(actor: ActorCell): Unit
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference
- Attributes
- protected[akka]
- Definition Classes
- MessageDispatcher
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
systemDispatch(receiver: ActorCell, invocation: SystemMessage): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
throughput: Int
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
throughputDeadlineTime: Duration
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
toString: String
- Definition Classes
- Dispatcher → AnyRef → Any
-
final
def
unbatchedExecute(r: Runnable): Unit
- Attributes
- protected
- Definition Classes
- MessageDispatcher → BatchingExecutor
-
def
unregister(actor: ActorCell): Unit
If you override it, you must call it.
If you override it, you must call it. But only ever once. See "detach" for the only invocation
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- PinnedDispatcher → MessageDispatcher
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
→[B](y: B): (PinnedDispatcher, B)
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to ArrowAssoc[PinnedDispatcher] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
Deprecated Value Members
-
def
prepare(): ExecutionContext
- Definition Classes
- ExecutionContext
- Annotations
- @deprecated
- Deprecated
(Since version 2.12.0) preparation of ExecutionContexts will be removed
Inherited from Dispatcher
Value Members
-
def
createMailbox(actor: Cell, mailboxType: MailboxType): Mailbox
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
def
dispatch(receiver: ActorCell, invocation: Envelope): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
def
executeTask(invocation: TaskInvocation): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
final
def
executorService: ExecutorServiceDelegate
- Attributes
- protected
- Definition Classes
- Dispatcher
-
val
id: String
- Definition Classes
- Dispatcher → MessageDispatcher
-
def
registerForExecution(mbox: Mailbox, hasMessageHint: Boolean, hasSystemMessageHint: Boolean): Boolean
Returns if it was registered
Returns if it was registered
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
def
shutdown(): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
shutdownTimeout: FiniteDuration
- Definition Classes
- Dispatcher → MessageDispatcher
-
def
systemDispatch(receiver: ActorCell, invocation: SystemMessage): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
throughput: Int
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
throughputDeadlineTime: Duration
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
toString: String
- Definition Classes
- Dispatcher → AnyRef → Any
Inherited from MessageDispatcher
Value Members
-
final
def
attach(actor: ActorCell): Unit
Attaches the specified actor instance to this dispatcher, which includes scheduling it to run for the first time (Create() is expected to have been enqueued by the ActorCell upon mailbox creation).
Attaches the specified actor instance to this dispatcher, which includes scheduling it to run for the first time (Create() is expected to have been enqueued by the ActorCell upon mailbox creation).
- Definition Classes
- MessageDispatcher
-
val
configurator: MessageDispatcherConfigurator
- Definition Classes
- MessageDispatcher
-
final
def
detach(actor: ActorCell): Unit
Detaches the specified actor instance from this dispatcher
Detaches the specified actor instance from this dispatcher
- Definition Classes
- MessageDispatcher
-
val
eventStream: EventStream
- Definition Classes
- MessageDispatcher
-
final
def
inhabitants: Long
- Definition Classes
- MessageDispatcher
-
final
val
isThroughputDeadlineTimeDefined: Boolean
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- MessageDispatcher
-
val
mailboxes: Mailboxes
- Definition Classes
- MessageDispatcher
-
def
reportFailure(t: Throwable): Unit
- Definition Classes
- MessageDispatcher → ExecutionContext
-
final
def
resubmitOnBlock: Boolean
- Attributes
- protected
- Definition Classes
- MessageDispatcher → BatchingExecutor
-
def
resume(actor: ActorCell): Unit
- Attributes
- protected[akka]
- Definition Classes
- MessageDispatcher
-
def
suspend(actor: ActorCell): Unit
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference
- Attributes
- protected[akka]
- Definition Classes
- MessageDispatcher
-
final
def
unbatchedExecute(r: Runnable): Unit
- Attributes
- protected
- Definition Classes
- MessageDispatcher → BatchingExecutor
Inherited from ExecutionContext
Value Members
-
def
prepare(): ExecutionContext
- Definition Classes
- ExecutionContext
- Annotations
- @deprecated
- Deprecated
(Since version 2.12.0) preparation of ExecutionContexts will be removed
Inherited from BatchingExecutor
Inherited from AnyRef
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Inherited from Any
Inherited by implicit conversion any2stringadd from PinnedDispatcher to any2stringadd[PinnedDispatcher]
Value Members
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to any2stringadd[PinnedDispatcher] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
Inherited by implicit conversion StringFormat from PinnedDispatcher to StringFormat[PinnedDispatcher]
Value Members
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to StringFormat[PinnedDispatcher] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
Inherited by implicit conversion Ensuring from PinnedDispatcher to Ensuring[PinnedDispatcher]
Value Members
-
def
ensuring(cond: (PinnedDispatcher) ⇒ Boolean, msg: ⇒ Any): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (PinnedDispatcher) ⇒ Boolean): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
Inherited by implicit conversion ArrowAssoc from PinnedDispatcher to ArrowAssoc[PinnedDispatcher]
Value Members
-
def
->[B](y: B): (PinnedDispatcher, B)
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to ArrowAssoc[PinnedDispatcher] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
def
→[B](y: B): (PinnedDispatcher, B)
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to ArrowAssoc[PinnedDispatcher] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
Ungrouped
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to any2stringadd[PinnedDispatcher] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (PinnedDispatcher, B)
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to ArrowAssoc[PinnedDispatcher] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
final
def
attach(actor: ActorCell): Unit
Attaches the specified actor instance to this dispatcher, which includes scheduling it to run for the first time (Create() is expected to have been enqueued by the ActorCell upon mailbox creation).
Attaches the specified actor instance to this dispatcher, which includes scheduling it to run for the first time (Create() is expected to have been enqueued by the ActorCell upon mailbox creation).
- Definition Classes
- MessageDispatcher
-
def
batchable(runnable: Runnable): Boolean
Override this to define which runnables will be batched.
Override this to define which runnables will be batched.
- Definition Classes
- BatchingExecutor
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
val
configurator: MessageDispatcherConfigurator
- Definition Classes
- MessageDispatcher
-
def
createMailbox(actor: Cell, mailboxType: MailboxType): Mailbox
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
final
def
detach(actor: ActorCell): Unit
Detaches the specified actor instance from this dispatcher
Detaches the specified actor instance from this dispatcher
- Definition Classes
- MessageDispatcher
-
def
dispatch(receiver: ActorCell, invocation: Envelope): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
def
ensuring(cond: (PinnedDispatcher) ⇒ Boolean, msg: ⇒ Any): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (PinnedDispatcher) ⇒ Boolean): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): PinnedDispatcher
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to Ensuring[PinnedDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
val
eventStream: EventStream
- Definition Classes
- MessageDispatcher
-
def
execute(runnable: Runnable): Unit
- Definition Classes
- BatchingExecutor → Executor
-
def
executeTask(invocation: TaskInvocation): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
final
def
executorService: ExecutorServiceDelegate
- Attributes
- protected
- Definition Classes
- Dispatcher
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to StringFormat[PinnedDispatcher] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
val
id: String
- Definition Classes
- Dispatcher → MessageDispatcher
-
final
def
inhabitants: Long
- Definition Classes
- MessageDispatcher
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
val
isThroughputDeadlineTimeDefined: Boolean
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- MessageDispatcher
-
val
mailboxes: Mailboxes
- Definition Classes
- MessageDispatcher
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
def
register(actorCell: ActorCell): Unit
If you override it, you must call it.
If you override it, you must call it. But only ever once. See "attach" for only invocation.
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- PinnedDispatcher → MessageDispatcher
-
def
registerForExecution(mbox: Mailbox, hasMessageHint: Boolean, hasSystemMessageHint: Boolean): Boolean
Returns if it was registered
Returns if it was registered
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
def
reportFailure(t: Throwable): Unit
- Definition Classes
- MessageDispatcher → ExecutionContext
-
final
def
resubmitOnBlock: Boolean
- Attributes
- protected
- Definition Classes
- MessageDispatcher → BatchingExecutor
-
def
resume(actor: ActorCell): Unit
- Attributes
- protected[akka]
- Definition Classes
- MessageDispatcher
-
def
shutdown(): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
shutdownTimeout: FiniteDuration
- Definition Classes
- Dispatcher → MessageDispatcher
-
def
suspend(actor: ActorCell): Unit
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference
- Attributes
- protected[akka]
- Definition Classes
- MessageDispatcher
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
systemDispatch(receiver: ActorCell, invocation: SystemMessage): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
throughput: Int
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
throughputDeadlineTime: Duration
- Definition Classes
- Dispatcher → MessageDispatcher
-
val
toString: String
- Definition Classes
- Dispatcher → AnyRef → Any
-
final
def
unbatchedExecute(r: Runnable): Unit
- Attributes
- protected
- Definition Classes
- MessageDispatcher → BatchingExecutor
-
def
unregister(actor: ActorCell): Unit
If you override it, you must call it.
If you override it, you must call it. But only ever once. See "detach" for the only invocation
INTERNAL API
- Attributes
- protected[akka]
- Definition Classes
- PinnedDispatcher → MessageDispatcher
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
→[B](y: B): (PinnedDispatcher, B)
- Implicit
- This member is added by an implicit conversion from PinnedDispatcher to ArrowAssoc[PinnedDispatcher] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
-
def
prepare(): ExecutionContext
- Definition Classes
- ExecutionContext
- Annotations
- @deprecated
- Deprecated
(Since version 2.12.0) preparation of ExecutionContexts will be removed