java - 如果 Disruptor 中的 next() 和publish() 之间抛出异常会发生什么？

Question

使用 Disruptor 或 publish() 时，如果在 next() 和 publish() 之间抛出异常，会发生什么情况 因其他原因或在可接受的时间内没有被调用？

处理此类情况的恢复/超时技术是什么？

Answer 1

在Disruptor中，它对发布的 self 调用位于finally block 中，以确保它们始终被调用。例如Disruptor.java#1017-1027

当发布将插槽标记为可用于事件处理程序时，它们将停止，直到发生发布调用。

恢复策略是不要破坏它;)也就是说，在您准备好使用它并始终调用发布之前，没有必要或没有意义声明您的插槽。如果您不想发布您已声明该插槽的数据，则可能需要在该插槽中添加某种错误标记。