它似乎 threads.blockingCallFromThread 即使反应堆停止,也会继续阻塞。有什么办法可以解除封锁吗?它阻塞的延迟依赖于来自另一端的 RPC,并且在反应器停止时肯定不会出现。

有帮助吗?

解决方案

它会阻塞直到延迟触发。如果您希望它解锁,请触发 Deferred。如果您要停止应用程序并停止反应器,那么您可能需要在执行此操作之前触发 Deferred。你可能想用 Failure 因为想必您还无法得出成功的结果。您可以安装reactor shutdown hooks以在reactor即将停止时运行代码,或者使用自定义 Service 或者 reactor.addSystemEventTrigger.

许可以下: CC-BY-SA归因
不隶属于 StackOverflow
scroll top