Akka演员之间的长时间延迟

Question

我经常看到两个参与者之间有很长的延迟(60+秒），从第一个参与者发送消息到第二个参与者，以及第二个参与者的onreceive方法随消息实际调用时。我可以寻找哪些类型的东西来调试这个问题？

ActorA的每个实例都使用ActorRef.tell（Object,ActorRef)为ActorB发送一条消息。在ActorA中调用tell方法并在ActorB的onReceive(Object)开始处获得另一个时间戳之后，我立即收集了一个毫秒时间戳（使用System.CurrentTimeMillis())。这些时间戳之间的间隔一致为60秒或更长。具体地说，当按时间绘制时，该间隔遵循从60秒到几乎120秒的粗糙锯齿模式，如下图所示。

这些参与者是系统数据流的早期参与者，在actorb之后还有其他几个参与者。这种大的差距只发生在这两个特定的行动者之间，其他相邻行动者对之间的差距通常小于一毫秒，偶尔几十毫秒。此外，在任何给定的执行元中所花费的实际时间永远不会超过一秒。

通常，系统中的每个actor只向另一个actor传递单个消息。其中一个参与者（在ActorB之后）向几个不同的参与者中的每一个发送单个消息，并且在一个很小的百分比（小于0.1%）的时间中，某些参与者将向相同的后续参与者发送多个消息（即，将要求后续参与者的多个实例）。当发生这种情况时，多个消息的数量通常为十几个或更少。

这能解释（明确地）由正常的反应性质的Akka吗？它是否表明工作的分发方式或参与者的配置方式存在问题？有什么东西可以明确地阻止一个特定的行动者旋转吗？我还应该收集或查看哪些其他信息来了解这个问题的来源，或者了解它是否是一个问题？

Answer 1

您有一个有限的线程池。如果您的执行元阻塞，它们仍然占用线程池中的空间。如果线程池已饱和，则不会创建新线程。

您可能希望配置core-pool-size-factor、core-pool-size-min和core-pool-size-max。

如果希望阻止某些操作，则可以将它们包装在future{blocking{...}}中并注册回调。但最好使用异步、非阻塞调用。