scala – 如果我们没有定义路由器,Akka Actor是否并行运行？

发布时间：2020-12-16 10:05:40 所属栏目：安全来源：网络整理

导读：我不太清楚Akka系统中的Router,Dispatcher和Executor. 如果我没有定义一个路由器,因此不给它一个组actor,那么actor是否并行运行？如果我没有定义路由器,但定义并使用调度程序： my-dispatcher { type = Dispatcher executor = "fork-join-executor" fork-jo

我不太清楚Akka系统中的Router,Dispatcher和Executor.

如果我没有定义一个路由器,因此不给它一个组actor,那么actor是否并行运行？

如果我没有定义路由器,但定义并使用调度程序：

my-dispatcher {
  type = Dispatcher
  executor = "fork-join-executor"
  fork-join-executor {
    parallelism-min = 2
    parallelism-factor = 2.0
    parallelism-max = 10
  }
  throughput = 100
}

演员是否并行奔跑？

解决方法

If I do not define a router and therefore do not give it a group
actors,the actor runs in parallel or not?

Actor系统中的Dispatcher是ExecutionContext的包装器,它具有执行actor的基础线程池.如果您创建的只是一个actor并将消息传递给它,那么所有消息都将到达同一个actor邮箱,然后逐个处理. actor内部的执行同步发生.

如果您希望多个actor处理请求,那么这正是路由器的用途.如果你想拥有一组可以处理相同请求的actor,你可以分配一个路由器,它将为你管理一组actor,注意哪个actor可以获得多少工作量.

一个例子是当你有一个路由器并且你定义了一个内部的actor池,即一个RoundRobinPool,它只是以循环方式将消息分配给actor邮箱：

context.actorOf(
  Props(new MyActor())
    .withRouter(RoundRobinPool(nrOfInstances = 10)),name = "MyRouter")

这将创建一个带有RoundRobinPool的路由器,其中包含10个actor.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!