Disruptor源码分析之Sequenced Sequenced是对于生产者和RingBuffer之间操作协调的一个抽象概念类,通过Sequenced定义生产者所需要的原子操作,保证序号分配的线程安全性和正确性,下面就对Sequenced进行详细分析 源码分析 Sequenced Sequenced.java Sequenced的主要方法分为三部分:管理、获取地址、发布, 管理方法主要是获...

Disruptor源码分析之RingBuffer RingBuffer是Disruptor的核心组件之一,它是一个高效的环形缓冲区,用于在生产者和消费者之间传递事件对象,RingBuffer通过预分配内存和无锁设计实现了高性能的数据传输,本文将深入分析RingBuffer的源码实现,包括其继承结构、属性、初始化过程以及读写逻辑。 RingBuffer类 可用看到RingBuffer继承实现Rin...

Disruptor之理论基础 disruptor的设计理念主要围绕以下几个核心思想:无锁设计,缓存行填充,序列号机制,事件驱动,高吞吐量; 传统队列的一些问题 锁性能瓶颈 锁提供了一种互斥机制,通过锁可以保证数据安全性,但是锁的使用会带来性能瓶颈,根据Disruptor官网的说法使用锁的成本如下 可以看到性能如下:无锁 > valatile > CAS > lock,其中可...

Disruptor之基础入门 什么是Disruptor Disruptor是一个高性能的并发编程框架，旨在提供低延迟和高吞吐量的数据处理能力。它由LMAX交易所开发，最初用于金融交易系统，但其设计理念和实现方式使其适用于各种需要高性能数据处理的场景; 核心的设计理念是认为队列是一种糟糕的抽象，因为它暗示了数据必须在不同上下文之间被复制排队进行处理,LMAX Disruptor哲学核心是通过共享内存...

深入理解分布式事务-原理与实践-分布式事务原理 在上一章中已经介绍了分布式事务的基础知识了,这一章将会介绍主要的几种分布式事务的原理,包括XA强一致性分布式事务原理、TCC分布式事务原理、可靠消息型分布式事务原理、最大努力通知型分布式事务原理 XA强一致性分布式事务原理 X/Open组织定于的分布式事务标准规划被称为X/Open DTP模型,定义了事务处理的规划和API,具体的实现由各个厂商进行负...

CompletableFuture常用方法总结 下文对CompletableFuture类中的常用方法进行了总结,以备不时之需; 创建方法 示例 supplyAsync() fun supplyAsync() { val future = CompletableFuture.supplyAsync { return@supplyAsync Futur...