3

我正在使用适用于 Akka 2.0 的 Java API，并且有一种下沉的感觉，即我没有正确使用 ActorSystem 来启动和/或/xor 停止 TypedActors。当应用程序关闭时，java 进程不会终止。经过调试，我看到默认调度程序仍然有多个正在运行的线程，并且调度程序仍在运行。在下面的示例中，有什么明显的我做错了吗？

Config akkaConf = ConfigFactory.load();
ActorSystem actorSystem = ActorSystem.create("myApp", akkaConf);

TypedProps<Actor1Impl> actor1TypedProps = new TypedProps<Actor1Impl>(Actor1Interface.class, new Creator<Actor1Impl>(
    public Actor1Impl create() {
        return new Actor1Impl(nonDefault, constructor, scalaIsSo, muchMoreElegant);
    }
);
Actor1Interface a1 = TypedActor.get(actorSystem).typedActorOf(actor1TypedProps, "anA1Actor");

读者不知道（为了简洁起见），Actor1Impl 类实现了 TypedActor.PreStart 和 .PostStop。在 PreStart 中，它会安排一个 Runnable 任务定期执行。我认为这可以保持调度程序处于活动状态，但我还保存了返回的 Cancellable，我相信我应该在 PostStop 块中取消它。这无助于终止调度程序线程。无论如何，回到故事...

还有许多其他的actor类型，每一个都有一个非标准的构造函数。其中一些向调度程序注册定期 Runnable，就像上面的 Actor1Impl 一样。为了更有趣，有些甚至需要其他 Actor 作为构造函数参数，以便让 Actor 注册回调，如下所示：

public Actor2Impl(Actor1Interface a1) {
    a1.registerCallback(TypedActor.<Actor2Interface>self());
}

在确定应用程序已过期后，将执行以下操作：

TypedActor.get(actorSystem).stop(a1);
TypedActor.get(actorSystem).stop(a2);
...
TypedActor.get(actorSystem).stop(aN);
actorSystem.shutdown();

有什么我正在做的明显错误的事情会阻止java进程终止吗？具体来说，有什么会导致调度程序和默认调度程序关闭？

4

0 回答 0