Java Disruptor 处理异常

Question

在disruptor(版本3.3.2)中，每个事件都是一个Runnable(因为EventProcessor扩展了runnable)。

我正在编写一个应用程序，每当EventHandler抛出异常时，调用disruptor.start()的类需要捕获异常然后使用react。

现在，如果 EventProcessor 是 Callable，那就很容易了。

Disruptor 中是否有其他方法来传播异常？

Answer 1

我通过将实现接口(interface)传递给EventHandler解决了这个问题，正如道格·李 (Doug Lea) 书中所建议的那样。异常是在 LinkedList 中设置的，并且在方法调用结束时我检索列表中的最后一个元素。示例代码:

    final LinkedList<Throwable> listExceptions = new LinkedList<Throwable>();

    MyClassWithDisruptor at = MyClassWithDisruptor.getInstance();
    at.send(message, transport, conf, new AuditExceptionHandler() {

        @Override
        public void handleException(final Throwable e) {
            e.printStackTrace();

        }

        @Override
        public void setException(final Exception e) throws AuditTrailException {
            listExceptions.add(e);

        }
    });