akka.dispatch

Dispatchers

object Dispatchers extends AnyRef

Scala API. Dispatcher factory.

Example usage:

  val dispatcher = Dispatchers.newExecutorBasedEventDrivenDispatcher("name")
  dispatcher
    .withNewThreadPoolWithLinkedBlockingQueueWithCapacity(100)
    .setCorePoolSize(16)
    .setMaxPoolSize(128)
    .setKeepAliveTimeInMillis(60000)
    .build

Java API. Dispatcher factory.

Example usage:

  MessageDispatcher dispatcher = Dispatchers.newExecutorBasedEventDrivenDispatcher("name");
  dispatcher
    .withNewThreadPoolWithLinkedBlockingQueueWithCapacity(100)
    .setCorePoolSize(16)
    .setMaxPoolSize(128)
    .setKeepAliveTimeInMillis(60000)
    .build();

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. Dispatchers
  2. AnyRef
  3. 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 DEFAULT_SHUTDOWN_TIMEOUT : Duration

  7. val MAILBOX_CAPACITY : Int

  8. val MAILBOX_PUSH_TIME_OUT : Duration

  9. val MAILBOX_TYPE : MailboxType

  10. val THROUGHPUT : Int

  11. val THROUGHPUT_DEADLINE_TIME : Duration

  12. val THROUGHPUT_DEADLINE_TIME_MILLIS : Int

  13. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  14. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  15. lazy val defaultGlobalDispatcher : MessageDispatcher

  16. def eq (arg0: AnyRef): Boolean

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

    Definition Classes
    AnyRef → Any
  18. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  19. def from (cfg: Configuration): Option[MessageDispatcher]

  20. def fromConfig (key: String, default: ⇒ MessageDispatcher = defaultGlobalDispatcher): MessageDispatcher

    Utility function that tries to load the specified dispatcher config from the akka.

    Utility function that tries to load the specified dispatcher config from the akka.conf or else use the supplied default dispatcher

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

    Attributes
    final
    Definition Classes
    AnyRef → Any
  22. object globalExecutorBasedEventDrivenDispatcher extends ExecutorBasedEventDrivenDispatcher

  23. def hashCode (): Int

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

    Attributes
    final
    Definition Classes
    Any
  25. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  26. def newExecutorBasedEventDrivenDispatcher (name: String, throughput: Int, throughputDeadlineMs: Int, mailboxType: MailboxType): ThreadPoolConfigDispatcherBuilder

    Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.

    Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.

    Has a fluent builder interface for configuring its semantics.

  27. def newExecutorBasedEventDrivenDispatcher (name: String, throughput: Int, mailboxType: MailboxType): ThreadPoolConfigDispatcherBuilder

    Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.

    Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.

    Has a fluent builder interface for configuring its semantics.

  28. def newExecutorBasedEventDrivenDispatcher (name: String): ThreadPoolConfigDispatcherBuilder

    Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.

    Creates a executor-based event-driven dispatcher serving multiple (millions) of actors through a thread pool.

    Has a fluent builder interface for configuring its semantics.

  29. def newExecutorBasedEventDrivenWorkStealingDispatcher (name: String, throughput: Int, throughputDeadlineMs: Int, mailboxType: MailboxType): ThreadPoolConfigDispatcherBuilder

    Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.

    Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.

    Has a fluent builder interface for configuring its semantics.

  30. def newExecutorBasedEventDrivenWorkStealingDispatcher (name: String, throughput: Int, mailboxType: MailboxType): ThreadPoolConfigDispatcherBuilder

    Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.

    Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.

    Has a fluent builder interface for configuring its semantics.

  31. def newExecutorBasedEventDrivenWorkStealingDispatcher (name: String, throughput: Int): ThreadPoolConfigDispatcherBuilder

    Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.

    Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.

    Has a fluent builder interface for configuring its semantics.

  32. def newExecutorBasedEventDrivenWorkStealingDispatcher (name: String): ThreadPoolConfigDispatcherBuilder

    Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.

    Creates a executor-based event-driven dispatcher, with work-stealing, serving multiple (millions) of actors through a thread pool.

    Has a fluent builder interface for configuring its semantics.

  33. def newThreadBasedDispatcher (actor: ActorRef, mailboxCapacity: Int, pushTimeOut: Duration): ThreadBasedDispatcher

    Creates an thread based dispatcher serving a single actor through the same single thread.

    Creates an thread based dispatcher serving a single actor through the same single thread. If capacity is negative, it's Integer.MAX_VALUE

    E.g. each actor consumes its own thread.

  34. def newThreadBasedDispatcher (actor: ActorRef, mailboxCapacity: Int): ThreadBasedDispatcher

    Creates an thread based dispatcher serving a single actor through the same single thread.

    Creates an thread based dispatcher serving a single actor through the same single thread. Uses the default timeout If capacity is negative, it's Integer.MAX_VALUE

    E.g. each actor consumes its own thread.

  35. def newThreadBasedDispatcher (actor: ActorRef): ThreadBasedDispatcher

    Creates an thread based dispatcher serving a single actor through the same single thread.

    Creates an thread based dispatcher serving a single actor through the same single thread. Uses the default timeout

    E.g. each actor consumes its own thread.

  36. def notify (): Unit

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

    Attributes
    final
    Definition Classes
    AnyRef
  38. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  39. def toString (): String

    Definition Classes
    AnyRef → Any
  40. def wait (): Unit

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

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from AnyRef

Inherited from Any