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 (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 active : Switch

    Attributes
    protected
    Definition Classes
    MessageDispatcher

  7. val aggregate : Boolean

  8. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any

  9. def attach (actorRef: ActorRef): Unit

    Attributes
    final
    Definition Classes
    MessageDispatcher

  10. def clone (): AnyRef

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

  11. def createMailbox (actorRef: ActorRef): AnyRef

    Definition Classes
    HawtDispatcher → MessageDispatcher

  12. def detach (actorRef: ActorRef): Unit

    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. val guard : ReentrantGuard

    Attributes
    protected
    Definition Classes
    MessageDispatcher

  19. def hashCode (): Int

    Definition Classes
    AnyRef → Any

  20. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any

  21. def mailboxSize (actorRef: ActorRef): Int

    Definition Classes
    HawtDispatcher → MessageDispatcher

  22. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  23. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  24. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  25. val parent : DispatchQueue

  26. def pendingFutures : Long

    Definition Classes
    MessageDispatcher

  27. def resume (actorRef: ActorRef): Unit

    Definition Classes
    HawtDispatcher → MessageDispatcher

  28. def stopAllAttachedActors : Unit

    Definition Classes
    MessageDispatcher

  29. def suspend (actorRef: ActorRef): Unit

    Definition Classes
    HawtDispatcher → MessageDispatcher

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

    Attributes
    final
    Definition Classes
    AnyRef

  31. def toString (): String

    Definition Classes
    HawtDispatcher → 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 MessageDispatcher

Inherited from AnyRef

Inherited from Any