java - 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 能否处理有时需要数小时才能从执行中返回的 Actor ？

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)

间接回答，

future 优先

我完全同意 Akka Actors 对于特定类型的工作来说是一个非常有用的工具。在缓存方面，Actor 和 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 ，但卡路里减半!

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