guava - EventBus google guava 关闭 Hook

Question

目前我在我的应用程序中使用 guava EventBus 方法。监听器尝试做一些工作，如果失败，事件应该回到总线并重新发送。
我的问题是:如果我的应用程序出现故障(执行关闭)怎么办？它会在总线上发送剩余的事件吗？

我正在寻找一些方法，例如在 ActiveMQ shut down hoow 中实现的方法

should the broker install a shutdown hook so that it can properly shut itself down on a JVM kill

不幸的是，我没有在 EventBus guava 中找到类似的东西。

Answer 1

标准的 Guava EventBus 是同步的，它没有内部的 Thread 或类似的东西。如果调用 post(Object event) 的线程终止，EventBus 将停止传递事件(因为它使用调用者的线程)。

另一方面，AsyncEventBus 在构建期间采用了一个Executor(来自java.util.concurrent 包)，用于调度事件。在这种情况下，这取决于您使用的执行程序实现。例如，ThreadPoolExecutor 需要调用 shutdownNow() 来停止传递消息。