Disruptor本地线程队列_FatalException这个错误怎么解决?FatalExceptionHandler---线程间通信工作笔记007_disruptor怎么设置setdefaultexceptionhandler不会丢失数据

这个错误的解决方法,首先可以看一下另一个博文,

Disruptor本地线程队列_WorkProcessor异常_FatalExceptionHandler---线程间通信工作笔记004

这里说了怎么错误的原因,其实就是因为,任务在执行过程中,报错了,然后,disruptor,默认是调用的

FatalExceptionHandler来处理异常的,而可以去看一下,这个FatalExceptionHandler,他的源码

就可以知道,这个处理异常的方式,仅仅是把异常进行抛出,那么在worker线程中,抛出异常的话,

会导致,worker线程停止,所以就要,改变,异常的处理方式.怎么改变呢?

可以这样:

disruptor.setDefaultExceptionHandler(exceptionHandler);

在声明完了disruptor以后,设置一下默认的异常处理器,这个异常处理器可以是自己定义的,也可以是

系统提供的:比如:IgnoreExceptionHandler 不要用FatalExceptionHandler,因为这个异常处理会把

异常抛出去.会导致任务停止运行.