LMAX干扰器依赖关系图/带SequenceBarrier的选通

Question

我试图在处理程序之间创建一种循环依赖关系，但我不太清楚如何正确处理。我想要实现的是制作人的变体-

所以，破坏者。handleEventsWith（h1、h2、h3）。然后（h4） 。但我还有其他要求

1. 虽然处理程序1-3并行处理消息，但在它们都完成前一条消息之前，它们都不会开始处理下一条消息。
2. 在第一条消息之后，处理程序1-3等待处理程序4完成最近的消息，然后再处理下一条消息。

使用单个事件处理程序的等效执行逻辑可以是：

disruptor.handleEventsWith((event, sequence, endOfBatch) -> {
  Arrays.asList(h1, h2, h3).parallelStream()
        .forEach(h -> h.onEvent(event, sequence, endOfBatch));
  h4.onEvent(event, sequence, endOfBatch);
});

设计上下文是处理程序1-3各自根据消息更新自己的状态，并且在消息被三个处理程序中的每一个处理后，它们处于一致状态。然后，处理程序4根据处理程序1-3更新的状态运行一些逻辑。因此，处理程序4应该只看到1-3维护的数据结构的一致状态，这意味着处理程序1-3在处理程序4完成之前不应该处理下一条消息。

（尽管目标肯定是使用Disruptor来管理并发性，而不是java.util.Stream）

不确定这是否重要，但处理程序4的逻辑也可以分为两部分，一部分要求处理程序1-3都没有更新，另一部分只要求处理程序4的第一部分已经完成。因此处理程序1-3可以在处理程序4的第二部分仍在执行时处理消息。

有没有办法做到这一点？或者我的设计有缺陷？我觉得应该有一种方法可以通过SequenceBarrier来做到这一点，但我不太明白如何实现这个自定义屏障。对于处理程序1-3，我想我想用逻辑处理程序[1:3]. lastProcessedSequence（）==handler[4]. lastProcessedSequence（）制作一个屏障，但我不确定将该逻辑放在哪里。

谢谢

Answer 1

我会考虑让处理程序是无状态的，并使用它们处理的消息来包含系统的状态。这样，您根本不需要同步处理程序。