标签：知识点 name disruptor -- Disruptor MsgConsumer new public

1. Disruptor
   1. 

       

   2. 

   3. 

   4. 

       

       

   5. 

       

       

   6.  

      volatile关键字的作用:保证可见性，禁止指令重排，不保证原子性

   7.  

      简单用法：

   8. 

       

       

   9. 

       

       

   10. 

        

        

   11. //消费者
       public class MsgConsumer implements EventHandler<MsgEvent>{
           private String name;
           public MsgConsumer(String name){
               this.name = name;
           }
           @Override
           public void onEvent(MsgEvent msgEvent, long l, boolean b) throws Exception {
               System.out.println(this.name+" -> 接收到信息： "+msgEvent.getValue());
           }
       }
       
       //生产者处理
       public class MsgProducer {
           private Disruptor disruptor;
           public MsgProducer(Disruptor disruptor){
               this.disruptor = disruptor;
           }
       
           public void send(String data){
               RingBuffer<MsgEvent> ringBuffer = this.disruptor.getRingBuffer();
               long next = ringBuffer.next();
               try{
                   MsgEvent event = ringBuffer.get(next);
                   event.setValue(data);
               }finally {
                   ringBuffer.publish(next);
               }
           }
       
           public void send(List<String> dataList){
               dataList.stream().forEach(data -> this.send(data));
           }
       }
       
       
       //触发测试
       public class DisruptorDemo {
           @Test
           public void test(){
               Disruptor<MsgEvent> disruptor = new Disruptor<>(MsgEvent::new, 1024, Executors.defaultThreadFactory());
       
               //定义消费者
               MsgConsumer msg1 = new MsgConsumer("1");
               MsgConsumer msg2 = new MsgConsumer("2");
               MsgConsumer msg3 = new MsgConsumer("3");
       
               //绑定配置关系
               disruptor.handleEventsWith(msg1, msg2, msg3);
               disruptor.start();
       
               // 定义要发送的数据
               MsgProducer msgProducer = new MsgProducer(disruptor);
               msgProducer.send(Arrays.asList("nihao","hah"));
           }
       }

        

   12.  

        

        

        

标签：知识点,name,disruptor,--,Disruptor,MsgConsumer,new,public
来源： https://www.cnblogs.com/zzhAylm/p/15499882.html

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