标签：Disruptor 调用 流程 start 线程 处理器 方法 运转

1.Disruptor的构造和初始化

可以调用Disruptor的构造函数初始化，可以设定线程池，等待策略，ringBuffer的大小等信息。

注意，在高版本的Disruptor中，带线程池的构造方法已经被打上了Deprecated标记，原文是这样解释的：

使用ThreadFactory来代替Executor的原因是为了能够在无法继续创建线程来执行producer任务的时候能够报告errors。

2.Disruptor的启动

可以调用Disruptor的start方法来启动。

ring buffer是为了阻止还没有被消费的slot被新的内容覆盖。

start方法只能在所有的event事件处理器都添加了之后执行一次。

代码里也做了校验，会首先判断这个方法是否有被调用过，如果调用过，直接抛出异常。

所以在start执行之前，需要添加所有的处理器，是通过下面这个方法实现的：

有几点需要注意：

首先这些已经添加的处理器是并行执行的，因为上面start方法中的consumerInfo的start是把该处理器放到线程池中处理的，所以是一个多线程执行的场景（除非这个线程池是same模式）

标签：Disruptor,调用,流程,start,线程,处理器,方法,运转
来源： https://blog.csdn.net/xxcupid/article/details/89139478

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。