具有Akka和长时间运行进程的actor模式

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可以处理演员有时需要几个小时才能从执行中返回吗？

Answer 1

直接回答您的问题；有一篇关于这个主题的好文章：

同样，如果您有长时间运行的计算，那么让它们在单独的 ExecutionContext 中运行以处理 CPU 密集型任务是一个好主意。

文章中有以下示例：

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是城里最好的游戏。

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

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

简单、简洁、异步。

没有杀死字母，没有接受任何东西的重载接收方法，也没有 Props，甚至不需要 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未来调度程序来控制调度程序行为。