调度器

依赖

调度器（Dispatchers）是核心 Akka 的一部分，这意味着它们是akka-actor-typed依赖的一部分：

  1. <!-- Maven -->
  2. <dependency>
  3.   <groupId>com.typesafe.akka</groupId>
  4.   <artifactId>akka-actor-typed_2.12</artifactId>
  5.   <version>2.5.23</version>
  6. </dependency>
  8. <!-- Gradle -->
  9. dependencies {
  10.   compile group: 'com.typesafe.akka', name: 'akka-actor-typed_2.12', version: '2.5.23'
  11. }
  13. <!-- sbt -->
  14. libraryDependencies += "com.typesafe.akka" %% "akka-actor-typed" % "2.5.23"

简介

Akka 的MessageDispatcher是Akka Actor tick的原因，可以说，它是机器的引擎。所有MessageDispatcher实现也是一个执行器，这意味着它们可以用于执行任意代码，例如「Futures」。

选择调度器

当不指定自定义调度器的时候，默认调度器用于生成所有 Actor。这适用于所有不阻塞的 Actor。阻塞 Actor 需要小心管理，「这里」有更多的细节。

要选择调度器，请使用DispatcherSelector创建用于生成 Actor 的Props实例：

  1. context.spawn(yourBehavior, "DefaultDispatcher");
  2. context.spawn(
  3.     yourBehavior, "ExplicitDefaultDispatcher", DispatcherSelector.defaultDispatcher());
  4. context.spawn(yourBehavior, "BlockingDispatcher", DispatcherSelector.blocking());
  5. context.spawn(
  6.     yourBehavior,
  7.     "DispatcherFromConfig",
  8.     DispatcherSelector.fromConfig("your-dispatcher"));

DispatcherSelector有两种方便的方法来查找默认的调度器和自定义调度器，你可以使用它来执行阻塞的 Actor，例如不支持CompletionStages的遗留数据库 API。

最后一个示例演示如何从配置中加载自定义调度器，并在application.conf中对此进行答复：

  1. your-dispatcher {
  2.   type = Dispatcher
  3.   executor = "thread-pool-executor"
  4.   thread-pool-executor {
  5.     fixed-pool-size = 32
  6.   }
  7.   throughput = 1
  8. }

有关如何配置自定义调度器的完整详细信息，请参阅「非类型化文档」。

英文原文链接：Dispatchers.