Package org.apache.pekko.dispatch

Class PinnedDispatcher

java.lang.Object

org.apache.pekko.dispatch.MessageDispatcher

org.apache.pekko.dispatch.Dispatcher

org.apache.pekko.dispatch.PinnedDispatcher

All Implemented Interfaces:

java.util.concurrent.Executor, BatchingExecutor, scala.concurrent.ExecutionContext, scala.concurrent.ExecutionContextExecutor

public 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 pekko.dispatch.Dispatchers.

Nested Class Summary

Nested classes/interfaces inherited from interface scala.concurrent.ExecutionContext

scala.concurrent.ExecutionContext.Implicits$, scala.concurrent.ExecutionContext.parasitic$

Constructor Summary

Constructors

Constructor	Description
PinnedDispatcher(MessageDispatcherConfigurator _configurator, org.apache.pekko.actor.ActorCell _actor, java.lang.String _id, scala.concurrent.duration.FiniteDuration _shutdownTimeout, ThreadPoolConfig _threadPoolConfig)

Method Summary

Modifier and Type	Method	Description
protected void	register(org.apache.pekko.actor.ActorCell actorCell)	If you override it, you must call it.
protected void	unregister(org.apache.pekko.actor.ActorCell actor)	If you override it, you must call it.

Methods inherited from class org.apache.pekko.dispatch.Dispatcher

batchable, createMailbox, dispatch, executeTask, executorService, id, registerForExecution, shutdown, shutdownTimeout, systemDispatch, throughput, throughputDeadlineTime, toString

Methods inherited from class org.apache.pekko.dispatch.MessageDispatcher

actors, attach, configurator, debug, detach, eventStream, inhabitants, isThroughputDeadlineTimeDefined, mailboxes, printActors, reportFailure, RESCHEDULED, resubmitOnBlock, resume, SCHEDULED, suspend, unbatchedExecute, UNSCHEDULED

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pekko.dispatch.BatchingExecutor

execute

Methods inherited from interface scala.concurrent.ExecutionContext

execute, prepare

Constructor Detail

PinnedDispatcher

public PinnedDispatcher(MessageDispatcherConfigurator _configurator,
                        org.apache.pekko.actor.ActorCell _actor,
                        java.lang.String _id,
                        scala.concurrent.duration.FiniteDuration _shutdownTimeout,
                        ThreadPoolConfig _threadPoolConfig)

Method Detail

register

protected void register(org.apache.pekko.actor.ActorCell actorCell)

Description copied from class: MessageDispatcher

If you override it, you must call it. But only ever once. See "attach" for only invocation.

INTERNAL API

Overrides:

register in class MessageDispatcher

unregister

protected void unregister(org.apache.pekko.actor.ActorCell actor)

Description copied from class: MessageDispatcher

If you override it, you must call it. But only ever once. See "detach" for the only invocation

INTERNAL API

Overrides:

unregister in class MessageDispatcher