1

我们有一个使用 Disruptor 框架的系统，它有五个注册阶段实现 EvenetHandler。

阶段按顺序工作，因此只有在第一阶段完成后，请求才能移动到第二阶段，这种移动由 Disruptor 内部维护。

我们在第三阶段遇到了问题，这是一个瓶颈，需要花费大量时间，因为它会进行不同的 HTTP 调用并将响应存储在请求对象中。

因此，在第三阶段花费了一段时间后，我们希望将请求（无论它有什么响应）提前到第四和第五阶段。

我如何使任何特定阶段（在这种情况下为第三阶段）超时并强制将请求移至下一阶段？

或者，

有没有办法注册一些在定义的超时后触发的事件，这可能类似于系统级超时？

4

1 回答 1

1

我们尝试的解决方案是

  1. 有一个挂起检测线程，它监视一个阶段（或所有阶段）处理的序列。在事件处理器本身中有一个计时信息。
  2. 超时中断事件处理器线程。这应该使事件处理器退出它正在执行的旋转。所以在这里我们失去了处理阶段的线程（或线程之一）
  3. 替换事件处理器线程。

解决方案需要编写我们自己的可感知中断的事件处理器，并提供将事件阶段动态添加到中断器的规定

于 2013-12-16T06:13:18.803 回答