执行元实例数

Question

我对akka-actor是一个新手，对一些问题感到困惑：

1. 当我创建actorSystem并使用actorOf(Props(ClassOf[AX]，...))在main方法中创建actor，我的ActorAX有多少实例？
2. 如果Q1的答案只有一个，那么这是否意味着我在AX actor类定义中创建的任何数据结构都只会出现在一个线程中，而我不应该关心并发问题？
3. 如果我执行元的一个操作（receive方法中的一个案例）是一个耗时的任务，并且需要相当长的时间才能完成，该怎么办？在完成该任务之前，我的单个执行元实例是否不会响应？
4. 如果问题3的答案是正确的，我应该做什么来防止我的演员不响应？我是否应该启动另一个线程并向其发送另一条消息，直到完成任务为止？有没有我应该遵循的最佳实践？

Answer 1

>

是的，每次调用“actor of”方法时，执行元系统只创建一个执行元实例。但是,当使用路由器时,可以创建1个路由器,从而将负载分散到任意数量的参与者。因此，在这种情况下，可以构造多个实例，但“通常”使用actorOf只创建一个实例。

是的，在actor中，您不必担心并发问题，因为Akka保证任何actor一次只处理一条消息。您必须注意不要以某种方式从执行元外部的代码中更改执行元的状态。因此，无论何时公开actor状态，都要使用不可变的类来执行此操作。案例类在这方面是非常好的。而且要注意在从参与者内部完成未来时修改参与者状态。由于Future在它自己的线程上运行，所以当Future完成时，执行元同时处理下一条消息时，可能会出现并发问题。执行元一次在1个线程上执行，但执行元每次执行时这可能是不同的线程。

Akka是一个高度并发和分布式的框架，所有的东西都是异步和非阻塞的，您必须在应用程序中做到这一点。Scala和Akka提供了几种解决方案来实现这一点。当您在一个actor中有一个耗时的任务时，您可以将这个耗时的任务委托给另一个actor，使用Futures或使用Scala的'async/await/blocking'。当使用'blocking'时，您会给编译器/运行时一个提示，即完成了一个阻塞操作，并且运行时可能会启动额外的线程以防止线程饥饿。Scala并发编程书是学习这些东西的极好指南。还可以查看并发包ScalaDocs和Scala新手指南。如果参与者真的必须等待耗时的任务完成，那么是的，您的参与者只能在该任务完成时做出响应。但这是一种非常‘请求-响应’的思维方式。试着从这件事中脱身。执行元还可以立即响应，指示任务已启动，并在任务完成后发送附加消息。对于耗时的任务，一定要使用不同的线程池，这样ActorSystem就不会因为所有可用的线程都被耗时的任务用完而被阻塞。对于Future的，您可以提供单独的ExecutionContext（不要为此使用ActorSystem的Dispatch context！），但是通过Akka的配置，您还可以配置某些参与者在不同的线程池上运行。