这个错误的解决方法,首先可以看一下另一个博文,
Disruptor本地线程队列_WorkProcessor异常_FatalExceptionHandler---线程间通信工作笔记004
这里说了怎么错误的原因,其实就是因为,任务在执行过程中,报错了,然后,disruptor,默认是调用的
FatalExceptionHandler来处理异常的,而可以去看一下,这个FatalExceptionHandler,他的源码
就可以知道,这个处理异常的方式,仅仅是把异常进行抛出,那么在worker线程中,抛出异常的话,
会导致,worker线程停止,所以就要,改变,异常的处理方式.怎么改变呢?
可以这样:
disruptor.setDefaultExceptionHandler(exceptionHandler);
在声明完了disruptor以后,设置一下默认的异常处理器,这个异常处理器可以是自己定义的,也可以是
系统提供的:比如:IgnoreExceptionHandler 不要用FatalExceptionHandler,因为这个异常处理会把
异常抛出去.会导致任务停止运行.