akka.dispatch

PriorityExecutorBasedEventDrivenDispatcher

class PriorityExecutorBasedEventDrivenDispatcher extends ExecutorBasedEventDrivenDispatcher with PriorityMailbox

A version of ExecutorBasedEventDrivenDispatcher that gives all actors registered to it a priority mailbox, prioritized according to the supplied comparator.

The dispatcher will process the messages with the _lowest_ priority first.

Linear Supertypes
PriorityMailbox, ExecutorBasedEventDrivenDispatcher, MessageDispatcher, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. PriorityExecutorBasedEventDrivenDispatcher
  2. PriorityMailbox
  3. ExecutorBasedEventDrivenDispatcher
  4. MessageDispatcher
  5. AnyRef
  6. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new PriorityExecutorBasedEventDrivenDispatcher (name: String, comparator: Comparator[MessageInvocation])

  2. new PriorityExecutorBasedEventDrivenDispatcher (name: String, comparator: Comparator[MessageInvocation], config: ThreadPoolConfig)

  3. new PriorityExecutorBasedEventDrivenDispatcher (name: String, comparator: Comparator[MessageInvocation], throughput: Int)

  4. new PriorityExecutorBasedEventDrivenDispatcher (name: String, comparator: Comparator[MessageInvocation], throughput: Int, mailboxType: MailboxType)

  5. new PriorityExecutorBasedEventDrivenDispatcher (name: String, comparator: Comparator[MessageInvocation], throughput: Int, throughputDeadlineTime: Int, mailboxType: MailboxType)

  6. new PriorityExecutorBasedEventDrivenDispatcher (name: String, comparator: Comparator[MessageInvocation], throughput: Int, throughputDeadlineTime: Int, mailboxType: MailboxType, config: ThreadPoolConfig)

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any

  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  6. val active : Switch

    Attributes
    protected
    Definition Classes
    MessageDispatcher

  7. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any

  8. def attach (actorRef: ActorRef): Unit

    Attaches the specified actorRef to this dispatcher

    Attaches the specified actorRef to this dispatcher

    Attributes
    final
    Definition Classes
    MessageDispatcher

  9. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  10. val comparator : Comparator[MessageInvocation]

    Definition Classes
    PriorityExecutorBasedEventDrivenDispatcher → PriorityMailbox

  11. def createMailbox (actorRef: ActorRef): AnyRef

    Definition Classes
    PriorityMailbox

  12. def detach (actorRef: ActorRef): Unit

    Detaches the specified actorRef from this dispatcher

    Detaches the specified actorRef from this dispatcher

    Attributes
    final
    Definition Classes
    MessageDispatcher

  13. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  14. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  15. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  16. val futures : AtomicLong

    Attributes
    protected
    Definition Classes
    MessageDispatcher

  17. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef

  18. def getMailbox (receiver: ActorRef): MessageQueue with ExecutableMailbox

    returns

    the mailbox associated with the actor

    Attributes
    protected
    Definition Classes
    ExecutorBasedEventDrivenDispatcher

  19. val guard : ReentrantGuard

    Attributes
    protected
    Definition Classes
    MessageDispatcher

  20. def hashCode (): Int

    Definition Classes
    AnyRef → Any

  21. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any

  22. def mailboxSize (actorRef: ActorRef): Int

    Returns the size of the mailbox for the specified actor

    Returns the size of the mailbox for the specified actor

    Definition Classes
    ExecutorBasedEventDrivenDispatcher → MessageDispatcher

  23. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  24. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  25. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  26. def pendingFutures : Long

    Returns the amount of futures queued for execution

    Returns the amount of futures queued for execution

    Definition Classes
    MessageDispatcher

  27. def resume (actorRef: ActorRef): Unit

    Definition Classes
    ExecutorBasedEventDrivenDispatcher → MessageDispatcher

  28. def stopAllAttachedActors : Unit

    Traverses the list of actors (uuids) currently being attached to this dispatcher and stops those actors

    Traverses the list of actors (uuids) currently being attached to this dispatcher and stops those actors

    Definition Classes
    MessageDispatcher

  29. def suspend (actorRef: ActorRef): 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

    Definition Classes
    ExecutorBasedEventDrivenDispatcher → MessageDispatcher

  30. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef

  31. val toString : String

    Definition Classes
    ExecutorBasedEventDrivenDispatcher → AnyRef → Any

  32. val uuids : ConcurrentSkipListSet[Uuid]

    Attributes
    protected
    Definition Classes
    MessageDispatcher

  33. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  34. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  35. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from PriorityMailbox

Inherited from ExecutorBasedEventDrivenDispatcher

Inherited from MessageDispatcher

Inherited from AnyRef

Inherited from Any