multithreading - akka actor 如何在底层线程上实现？

Question

给定一个执行上下文和一个线程池，akka/scala Actor 是如何安排/实现的？

Answer 1

我对这个话题困惑了很长时间。我假设线程和参与者之间存在某种关系。对于每个 Actor ，都有一个线程来承载它，所以我在想。每个线程可能有几个参与者在协作多任务模式下工作。

文档侧重于使用，并简单地涵盖了内部架构。您只需扩展 Actor上课，你会得到一个工作 Actor 。所以我试图猜测如何做到这一点，并想象每个 Actor有生命周期，比如异步等待消息队列，然后处理消息，然后开始。

那是一个完全错误的假设。虽然文档说“ Actor 生命周期”，但这并不意味着 Actor生命周期。提到的 Actor 是一个概念，而不是实现 Actor 的实际对象。类(class)。该对象被动地驻留在 java 堆中。

为了给这个概念注入(inject)活力，需要一群真正的 worker 参与的协调工作。它的核心是调度员。它包含所有参与者、线程和消息。当资源变得可用并且有可用于处理的消息时，调度程序激活。它需要一个适当的 Actor对象，将其接收方法包装在 runnable 中，并将其传递给备用线程。因此，对象没有生命周期，只有来自参与者系统的偶尔方法调用。

当你想到它时，它比我之前假设的方案更有意义。但是我很难从可用的文档中推断出它。它是由经验丰富的并发程序员编写的。持有actor类与其背后的actor概念的区别。他们知道 Actor 系统的调度程序就像操作系统的任务调度程序。因此，他们很快就切入主题并描述了每个人都熟悉的概念的各种口味和实现。

但这对新手来说并不容易。他不熟悉参与者系统上下文中的调度程序模式。我试图用谷歌搜索“调度程序模式”，它显示了与参与者系统无关的定义。

我很容易找到 double dispatch 、多调度和其他 OOP 主题。我发现了类似于 Akka 的路由器 message dispatcher 的东西. Actor 消息调度程序可能有一个不错的描述，但并不容易找到。

我希望我已经消除了误解。