akka.dispatch

HawtDispatcher

class HawtDispatcher extends MessageDispatcher

A HawtDispatch based MessageDispatcher. Actors with this dispatcher are executed on the HawtDispatch fixed sized thread pool. The number of of threads will match the number of cores available on your system.

Actors using this dispatcher are restricted to only executing non blocking operations. The actor cannot synchronously call another actor or call 3rd party libraries that can block for a long time. You should use non blocking IO APIs instead of blocking IO apis to avoid blocking that actor for an extended amount of time.

This dispatcher delivers messages to the actors in the order that they were producer at the sender.

HawtDispatch supports processing Non blocking Socket IO in both the reactor and proactor styles. For more details, see the HawtDispacherEchoServer.scala example.

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

Instance Constructors

  1. new HawtDispatcher (name: String, aggregate: Boolean, parent: DispatchQueue)

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. val aggregate : Boolean

  9. def asInstanceOf [T0] : T0

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

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

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  12. def createMailbox (actorRef: ActorRef): AnyRef

    Definition Classes
    HawtDispatcher → MessageDispatcher
  13. def detach (actorRef: ActorRef): Unit

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

    Attributes
    protected[akka]
    Definition Classes
    HawtDispatcher → MessageDispatcher
  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
    HawtDispatcher → MessageDispatcher
  20. def finalize (): Unit

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

    Attributes
    final
    Definition Classes
    AnyRef → Any
  22. val guard : ReentrantGuard

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

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

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

    Definition Classes
    HawtDispatcher → MessageDispatcher
  26. def mailboxSize (actorRef: ActorRef): Int

    Definition Classes
    HawtDispatcher → MessageDispatcher
  27. val name : String

    Definition Classes
    HawtDispatcher → MessageDispatcher
  28. def ne (arg0: AnyRef): Boolean

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

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

    Attributes
    final
    Definition Classes
    AnyRef
  31. val parent : DispatchQueue

  32. def register (actorRef: ActorRef): Unit

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

    Definition Classes
    HawtDispatcher → MessageDispatcher
  34. def shutdown (): Unit

    Attributes
    protected[akka]
    Definition Classes
    HawtDispatcher → MessageDispatcher
  35. def start (): Unit

    Attributes
    protected[akka]
    Definition Classes
    HawtDispatcher → MessageDispatcher
  36. def stopAllAttachedActors : Unit

    Definition Classes
    MessageDispatcher
  37. def suspend (actorRef: ActorRef): Unit

    Definition Classes
    HawtDispatcher → MessageDispatcher
  38. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  39. def tasks : Long

    Definition Classes
    MessageDispatcher
  40. def timeoutMs : Long

    Attributes
    protected[akka]
    Definition Classes
    MessageDispatcher
  41. def toString (): String

    Definition Classes
    HawtDispatcher → AnyRef → Any
  42. def unregister (actorRef: ActorRef): Any

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

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

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

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Deprecated Value Members

  1. def pendingFutures : Long

    Definition Classes
    MessageDispatcher
    Annotations
    @deprecated
    Deprecated

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

Inherited from MessageDispatcher

Inherited from AnyRef

Inherited from Any