com.lmax.disruptor 第2页

详解C++高性能无锁队列的原理与实现

1.无锁队列原理1.1.队列操作模型队列是一种非常重要的数据结构，其特性是先进先出（FIFO），符合流水线业务流程。在进程间通信、网络通信间经常采用队列做缓存，缓解数据处理压力。根据操作队列的场景分为：单生产者——单消费者、多生产者——单消费者、单生产者——多消费者、多生产者——多消费者四大模型。根...

高性能队列Disruptor的初体验!_java高性能队列

初探Disruptor1.概述Disruptor是一个高性能、低延迟的无锁队列替代方案，最初由LMAX公司开发，专为处理高吞吐量和低延迟的消息传递系统而设计。它利用环形缓冲区（RingBuffer）和无锁的生产者-消费者模型，大幅提升并发性能。相比传统的基于java.util.concur...

我用半天时间解决了困扰团队一年多的cpu使用率过高问题

1问题现象使用dockerstats发现机器上的有一个容器占用的cpu特别高，接近400%但系统几乎没负荷，只有一两个设备和用户。据同事说，这个现象持续很久了，从他接手项目就是这样。到现在至少有一年多了，一直没人知道是什么原因，只知道是历史遗留问题。正好周末我有空，就花了点时间研究一下。2使用...

Disruptor核心组件_核心处理组件

1.RingBuffer、DisruptorRingBuffer：基于数组的缓存实现，也是创建Sequencer与定义WaitStrategy的入口Disruptor：持有RingBuffer、消费者线程池Executor、消费者集合含ConsumerRepository等引用2.Sequenc...

Disruptor框架源码阅读-如何不重复消费

RingBuffer如何保证数据不丢失由于ringbuffer是一个环形的队列，那么生产者和消费者在遍历这个队列的时候，如何制衡呢？1、生产快，消费慢，数据丢失？生产者速度过快，导致一个对象还没消费完，就循环生产了一个新的对象要加入ringbuffer，导致消费不完整，造成数据丢失？我们注意到...

高性能并发队列Disruptor使用详解

基本概念Disruptor是一个高性能的异步处理框架,是一个轻量的Java消息服务JMS,能够在无锁的情况下实现队列的并发操作Disruptor使用环形数组实现了类似队列的功能,并且是一个有界队列.通常应用于生产者-消费者的场景Disruptor是一个观察者模式的实现Disruptor通过以下三种...