hub / github.com/LMAX-Exchange/disruptor

github.com/LMAX-Exchange/disruptor @4.0.0 sqlite

repository ↗ · DeepWiki ↗ · release 4.0.0 ↗

1,786 symbols 5,311 edges 240 files 424 documented · 24%

Extension points exported contracts — how you extend this code

Implementations translate another data representations into events claimed from the RingBuffer @param event [12 implementers]

src/main/java/com/lmax/disruptor/EventTranslatorOneArg.java

EventAccessor (Interface)

(no doc) [1 implementers]

src/perftest/java/com/lmax/disruptor/immutable/EventAccessor.java

ExceptionHandler (Interface)

Callback handler for uncaught exceptions in the event processing cycle of the BatchEventProcessor @param im [7 implementers]

src/main/java/com/lmax/disruptor/ExceptionHandler.java

EventTranslator (Interface)

Implementations translate (write) data representations into events claimed from the RingBuffer. When publish [12 implementers]

src/main/java/com/lmax/disruptor/EventTranslator.java

DataProvider (Interface)

Typically used to decouple classes from RingBuffer to allow easier testing @param The type provided by the [19 implementers]

src/main/java/com/lmax/disruptor/DataProvider.java

WaitStrategy (Interface)

Strategy employed for making EventProcessors wait on a cursor Sequence. [18 implementers]

src/main/java/com/lmax/disruptor/WaitStrategy.java

Core symbols most depended-on inside this repo

get

called by 256

src/main/java/com/lmax/disruptor/DataProvider.java

publish

called by 143

src/main/java/com/lmax/disruptor/Sequenced.java

called by 122

src/main/java/com/lmax/disruptor/Sequenced.java

createSingleProducer

called by 80

src/main/java/com/lmax/disruptor/RingBuffer.java

getSequence

called by 74

src/main/java/com/lmax/disruptor/EventProcessor.java

set

called by 65

src/main/java/com/lmax/disruptor/Sequence.java

handleEventsWith

called by 60

src/main/java/com/lmax/disruptor/dsl/Disruptor.java

build

called by 57

src/main/java/com/lmax/disruptor/BatchEventProcessorBuilder.java

Shape

Method 1,383

Class 368

Interface 26

Enum 9

Languages

Java100%

Modules by API surface

src/test/java/com/lmax/disruptor/RingBufferTest.java95 symbols

src/test/java/com/lmax/disruptor/dsl/DisruptorTest.java45 symbols

src/test/java/com/lmax/disruptor/RewindBatchEventProcessorTest.java41 symbols

src/jcstress/java/com/lmax/disruptor/SequenceStressVarHandleBarrier.java38 symbols

src/jcstress/java/com/lmax/disruptor/SequenceStressVarHandle.java38 symbols

src/jcstress/java/com/lmax/disruptor/SequenceStressUnsafe.java38 symbols

src/test/java/com/lmax/disruptor/BatchEventProcessorTest.java37 symbols

src/test/java/com/lmax/disruptor/alternatives/RingBufferUnsafe.java36 symbols

src/test/java/com/lmax/disruptor/alternatives/RingBufferArray.java36 symbols

src/main/java/com/lmax/disruptor/RingBuffer.java35 symbols

src/main/java/com/lmax/disruptor/dsl/Disruptor.java25 symbols

src/test/java/com/lmax/disruptor/SequencerTest.java24 symbols

Used by 10 indexed graphs manifest dependencies, hub-wide

github.com/alibaba/canal

github.com/apache/doris

github.com/apache/druid

github.com/apache/logging-log4j2

github.com/apache/rocketmq

github.com/crossoverJie/JCSprout

github.com/eugenp/tutorials

github.com/leehaut/spring-boot-all

github.com/open-metadata/OpenMetadata

github.com/questdb/questdb

For agents

$ claude mcp add disruptor \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact