Disruptor高性能线程消息传递并发框架的示例分析


这篇文章主要介绍了Disruptor高性能线程消息传递并发框架的示例分析,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。Disruptor是英国LMAX公司开源的高性能的线程间传递消息的并发框架,和jdk中的BlockingQueue非常类似,但是性能却是BlockingQueue不能比拟的,下面是官方给出的一分测试报告,可以直观的看出两者的性能区别:这么性能炸裂的框架肯定要把玩一番,试用前,我们先了解下disruptor的主要的概念,然后结合楼主的weblog项目(之前使用的BlockingQueue),来实践下RingBuffer:环形的缓冲区,消息事件信息的载体。曾经 RingBuffer 是 Disruptor 中的最主要的对象,但从3.0版本开始,其职责被简化为仅仅负责对通过 Disruptor 进行交换的数据(事件)进行存储和更新。在一些更高级的应用场景中,Ring Buffer 可以由用户的自定义实现来完全替代。Event:定义生产者和消费者之间进行交换的数据类型。EventFactory:创建事件的工厂类接口,由用户实现,提供具体的事件EventHandler:事件处理接口,由用户实现,用于处理事件。目前为止,我们了解以上核心内容即可,更多的详情,可以免费云主机域名移步wiki文档:https://github.com/LMAX-Exchange/disruptor核心架构图:改造boot-websocket-log项目,这是一个典型的生产者消费者模式的实例。然后将BlockingQueue替换成Disruptor,完成功能,有兴趣的可以对比下。第一步,定义事件类型第二步,定义事件工厂第三步,定义数据处理器第四步,创建Disruptor实操类,定义事件发布方法,发布事件感谢你能够认真阅读完这篇文章,希望小编分享的“Disruptor高性能线程消息传递并发框架的示例分析”这篇文章对大家有帮助,同时也希望大家多多支持百云主机,关注百云主机行业资讯频道,更多相关知识等着你来学习!

相关推荐: C语言怎么处理学生打分、计算时间、最少硬币问题

本文小编为大家详细介绍“C语言怎么处理学生打分、计算时间、最少硬币问题”,内容详细,步骤清晰,细节处理妥当,希望这篇“C语言怎么处理学生打分、计算时间、最少硬币问题”文章能帮助大家解决疑惑,下面跟着小编的思路慢慢深入,一起来学习新知识吧。假设有三种面值的硬币,…

免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

(0)
打赏 微信扫一扫 微信扫一扫
上一篇 09/13 20:30
下一篇 09/14 09:19

相关推荐