Disruptor-消费者是多线程的吗？

Question

关于破坏者，我有以下问题：

1. 消费者（事件处理器）没有实现他们实现EventHandler的任何可调用或可运行接口，那么他们如何能够并行运行，因此，例如，我有一个disruptor实现，其中有这样一个菱形模式

     c1
P1 - c2 - c4 - c5
     c3

其中c1到c3可以在p1之后并联工作，C4和C5在p1之后工作。

所以通常我会有这样的东西（P1和C1-C5是可运行/可调用的）

p1.start();
p1.join();

c1.start();
c2.start();
c3.start();
c1.join();
c2.join();
c3.join();

c4.start();
c4.join();
c5.start();
c5.join();

但是在Disruptor的情况下，我的事件处理程序都没有实现Runnable或Callable，那么中断器框架最终是如何并行运行它们的呢？

采取以下sceanrio：

我的消费者C2需要调用webservice来对事件进行一些注释，在SEDA中，我可以为这10个C2请求启动10个线程[用于将消息从队列中拉出，进行Webservice调用并更新下一个SEDA队列]，这将确保我不会依次等待10个请求中的每个请求的web服务响应，在这种情况下，作为单个实例的eventprocessor C2（if）将依次等待10个C2请求。

Answer 1

Disruptor的默认策略是多线程的，所以如果您的每个处理器都在不同的处理器（使用者）中工作，那么它应该是好的，并且您的处理器是多线程的。

Answer 2

EventHandler被组合到BatchEventProcessor的实例中，该实例是可运行的。

• BatchEventProcessor实现run（）循环

使用DSL时，Disruptor负责通过Executor实例创建这些线程。

• 您在Disruptor构造函数中提供了一个执行器

关于您的特定场景（即：长时间运行的事件处理程序），您可以参考以下问题：

• 解决LMAX中断器模式中的慢速使用者（eventProcessor）问题