akka.dispatch.Dispatchers

globalExecutorBasedEventDrivenDispatcher

object globalExecutorBasedEventDrivenDispatcher extends ExecutorBasedEventDrivenDispatcher

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

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 _tasks : AtomicLong

    Attributes
    protected
    Definition Classes
    MessageDispatcher
  7. val active : Switch

    Attributes
    protected
    Definition Classes
    MessageDispatcher
  8. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  9. def attach (actorRef: ActorRef): Unit

    Attaches the specified actorRef to this dispatcher

    Attaches the specified actorRef to this dispatcher

    Attributes
    final
    Definition Classes
    MessageDispatcher
  10. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  11. val config : ThreadPoolConfig

  12. def createMailbox (actorRef: ActorRef): AnyRef

    Creates and returns a mailbox for the given actor.

    Creates and returns a mailbox for the given actor.

    Definition Classes
    ExecutorBasedEventDrivenDispatcherMessageDispatcher
  13. def detach (actorRef: ActorRef): Unit

    Detaches the specified actorRef from this dispatcher

    Detaches the specified actorRef from this dispatcher

    Attributes
    final
    Definition Classes
    MessageDispatcher
  14. def dispatch (invocation: MessageInvocation): Unit

    Will be called when the dispatcher is to queue an invocation for execution

    Will be called when the dispatcher is to queue an invocation for execution

    Attributes
    protected[akka]
    Definition Classes
    ExecutorBasedEventDrivenDispatcherMessageDispatcher
  15. def dispatchMessage (invocation: MessageInvocation): Unit

    Attributes
    protected[akka] final
    Definition Classes
    MessageDispatcher
  16. def dispatchTask (block: () ⇒ Unit): Unit

    Attributes
    protected[akka] final
    Definition Classes
    MessageDispatcher
  17. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  18. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  19. def executeTask (invocation: TaskInvocation): Unit

    Attributes
    protected[akka]
    Definition Classes
    ExecutorBasedEventDrivenDispatcherMessageDispatcher
  20. val executorService : AtomicReference[ExecutorService]

    Attributes
    protected[akka]
    Definition Classes
    ExecutorBasedEventDrivenDispatcher
  21. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  22. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  23. def getMailbox (receiver: ActorRef): MessageQueue with ExecutableMailbox

    returns

    the mailbox associated with the actor

    Attributes
    protected
    Definition Classes
    ExecutorBasedEventDrivenDispatcher
  24. val guard : ReentrantGuard

    Attributes
    protected
    Definition Classes
    MessageDispatcher
  25. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  26. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  27. def mailboxIsEmpty (actorRef: ActorRef): Boolean

    Returns the "current" emptiness status of the mailbox for the specified actor

    Returns the "current" emptiness status of the mailbox for the specified actor

    Definition Classes
    ExecutorBasedEventDrivenDispatcherMessageDispatcher
  28. 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
    ExecutorBasedEventDrivenDispatcherMessageDispatcher
  29. val mailboxType : MailboxType

  30. val name : String

    Name of this dispatcher.

    Name of this dispatcher.

    Definition Classes
    ExecutorBasedEventDrivenDispatcherMessageDispatcher
  31. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  32. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  33. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  34. def reRegisterForExecution (mbox: MessageQueue with ExecutableMailbox): Unit

    Attributes
    protected[akka]
    Definition Classes
    ExecutorBasedEventDrivenDispatcher
  35. def register (actorRef: ActorRef): Unit

    Attributes
    protected[akka]
    Definition Classes
    MessageDispatcher
  36. def registerForExecution (mbox: MessageQueue with ExecutableMailbox): Unit

    Attributes
    protected[akka]
    Definition Classes
    ExecutorBasedEventDrivenDispatcher
  37. def resume (actorRef: ActorRef): Unit

  38. def shutdown (): Unit

    Called one time every time an actor is detached from this dispatcher and this dispatcher has no actors left attached

    Called one time every time an actor is detached from this dispatcher and this dispatcher has no actors left attached

    Attributes
    protected[akka]
    Definition Classes
    ExecutorBasedEventDrivenDispatcherMessageDispatcher
  39. def start (): Unit

    Called one time every time an actor is attached to this dispatcher and this dispatcher was previously shutdown

    Called one time every time an actor is attached to this dispatcher and this dispatcher was previously shutdown

    Attributes
    protected[akka]
    Definition Classes
    ExecutorBasedEventDrivenDispatcherMessageDispatcher
  40. 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
  41. 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
    ExecutorBasedEventDrivenDispatcherMessageDispatcher
  42. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  43. def tasks : Long

    Returns the amount of tasks queued for execution

    Returns the amount of tasks queued for execution

    Definition Classes
    MessageDispatcher
  44. val threadFactory : MonitorableThreadFactory

    Attributes
    protected[akka]
    Definition Classes
    ExecutorBasedEventDrivenDispatcher
  45. val throughput : Int

  46. val throughputDeadlineTime : Int

  47. def timeoutMs : Long

    When the dispatcher no longer has any actors registered, how long will it wait until it shuts itself down, in Ms defaulting to your akka configs "akka.

    When the dispatcher no longer has any actors registered, how long will it wait until it shuts itself down, in Ms defaulting to your akka configs "akka.actor.dispatcher-shutdown-timeout" or otherwise, 1 Second

    Attributes
    protected[akka]
    Definition Classes
    MessageDispatcher
  48. val toString : String

    Definition Classes
    ExecutorBasedEventDrivenDispatcher → AnyRef → Any
  49. def unregister (actorRef: ActorRef): Any

    Attributes
    protected[akka]
    Definition Classes
    MessageDispatcher
  50. val uuids : ConcurrentSkipListSet[Uuid]

    Attributes
    protected
    Definition Classes
    MessageDispatcher
  51. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  52. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  53. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Deprecated Value Members

  1. def pendingFutures : Long

    Returns the amount of futures queued for execution

    Returns the amount of futures queued for execution

    Definition Classes
    MessageDispatcher
    Annotations
    @deprecated
    Deprecated

    Will be removed for Akka 2.0, use 'tasks' instead

Inherited from ExecutorBasedEventDrivenDispatcher

Inherited from MessageDispatcher

Inherited from AnyRef

Inherited from Any