Akka：在儿童演员完成后停止演员

Question

我经常发现自己使用一个“主”角色，为子任务创建许多子角色。当子任务完成时，主角也应该停止自己。所以当清空时，我观察子角色并停止主角色context.children.is。

我经常使用这种模式，但因为我从未读过这方面的文章。我不确定，这是一个好主意还是失败的演员有问题。。。？

我已经读过Akka 2中的关机模式，但是这种方法在Java中似乎比我的解决方案更复杂？

以下是我针对具有两个子任务的主要参与者的伪代码：

class MainActor extends AbstractActor {

    public MainActor() {
        receive(ReceiveBuilder
                .match(SubTask1Response.class, this::handleSubTask1)
                .match(SubTask2Response.class, this::handleSubTask2)
                .match(Terminated.class, x -> checkFinished())
                .build());
    }

    @Override
    public void preStart() throws Exception {
        context().watch(context().actorOf(SubTask1Worker.props(), "subTask1"));
        context().watch(context().actorOf(SubTask2Worker.props(), "subTask2"));
    }

    private void checkFinished() {
        if(context().children().isEmpty()) {
            context().stop(self());
        }
    }

    // ...
}

（我必须使用Java8:-（，但如果您能提供另一种解决方案，我也很乐意阅读Scala代码）

Answer 1

所以context（）。儿童（）。isEmpty（）似乎按预期工作。

但是在调试我的Akka应用程序时，我发现了这种方法的另一个问题：当终止的消息到达MainActor时，它是不确定的：有时在示例中的子任务k1响应之前有终止的消息！

我现在已经改变了我的代码，以计数运行的孩子自己和递减的数量，每当Main Actor收到一个结果响应子任务[1,2]响应。

=