Class 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.

    • 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