具有 Akka 和长运行进程的参与者模式

Question

最近我一直在研究很棒的 Akka 框架，试图感受它并决定它是否适合我的项目。目前这个应用程序是一个普通的旧 java 应用程序，它通过调用各种外部 c++ 可执行文件来执行一些非常复杂的计算（有时计算可能需要数小时运行）。在代码中它看起来像这样

public static class Worker extends UntypedActor {
  // Run Very Long Process 
  public void onReceive(Object message) {
    if (message instanceof Work) {
        Work work = (Work) message;
        double result = veryLongProcess(work.getStart(),work.getNrOfElements());
        getSender().tell(new Result(result), getSelf());
    } else {
       unhandled(message);
    }
  }
}

我的问题是 Akka 可以处理演员有时需要几个小时才能 return 执行吗？

Answer 1

直接回答你的问题；关于这个主题有一个 good article：

Again, if you have long-running computations, having them run in a separate ExecutionContext for CPU-bound tasks is a good idea.

文章有如下例子：

import java.util.concurrent.Executors
import concurrent.ExecutionContext

//I added 'private' for the rest of the example
private val executorService = Executors.newFixedThreadPool(4)
private val executionContext = ExecutionContext.fromExecutorService(executorService)

间接回答，

期货优先

我完全同意 Akka Actors 对于特定类型的工作来说是一个非常有用的工具。在缓存方面，Actors 和 Agents 是最好的选择。

但是，在这种情况下，我建议利用 Future 而不是 Actor。您可以使 veryLongProcess 成为 private 函数。隐私将允许完全控制一次调用该方法的线程数：

def longProcessFut(start : Int, noOfElements : Int) : Future[Result] = Future {
  veryLongProcess(start, noOfElements)
}(executionContext)//controls the executing pool of veryLongProcess

简单、简洁、异步。

没有杀死字母，没有接受阳光下任何东西的重载接收方法，也没有 Props，Future 甚至不需要 ActorRef。膨胀，我说啤酒肚！

此外，由于 ?:

，您的用户无论如何都会创建一个 Future

//Actor user code, too verbose

val longProcessRef = actorSystem actorOf Props[Worker]

val fut : Future[Result] = (longProcessRef ? Work(0,42)).mapTo[Result]

与直接使用 Futures 相比

//happy user code

val fut : Future[Result] = longProcessFut(0, 42)

同样伟大的未来，但卡路里减半！

您可以按照评论中建议的相同方式控制 Future 的调度程序，这非常好。您甚至可以使用 actorSystem.dispatcher 作为您的 Future 调度程序来控制调度程序的行为。

Answer 2

如果长时间运行ning 业务逻辑/算法是增量的，产生中间结果 and/or 可以运行非常长时间那么您可能想重复使用此处的优秀设计片段：Incremental processing in an akka actor

具有 Akka 和长运行进程的参与者模式

The actor pattern with Akka and long running processes

java

scala

actor

akka

具有 Akka 和长 运行 进程的参与者模式

The actor pattern with Akka and long running processes

java

scala

actor

akka

具有 Akka 和长运行进程的参与者模式