MCPcopy Index your code
hub / github.com/conversant/disruptor

github.com/conversant/disruptor @1.2.21

Chat with this repo
repository ↗ · DeepWiki ↗ · release 1.2.21 ↗ · + Follow
559 symbols 1,786 edges 50 files 107 documented · 19% updated 16mo ago1.2.21 · 2022-10-18★ 323
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

Conversant ConcurrentQueue, Disruptor BlockingQueue and ConcurrentStack

Disruptor is the highest performing intra-thread transfer mechanism available in Java. Conversant Disruptor is the highest performing implementation of this type of ring buffer because it has almost no overhead and it exploits a particularly simple design.

2017 Conversant Disruptor - Still the World's Fastest

Getting Started

Run the maven build to build and use the package.

$ mvn -U clean package

Conversant Disruptor is on Maven Central

For Java 9 and above:

<dependency>
  <groupId>com.conversantmedia</groupId>
  <artifactId>disruptor</artifactId>
  <version>1.2.16</version>
</dependency>

A classifier is not required in the latest release.

Java 8 is only supported in 1.2.15 and earlier.

Java 7 is only supported in 1.2.10 and earlier.

<dependency>
  <groupId>com.conversantmedia</groupId>
  <artifactId>disruptor</artifactId>
  <version>1.2.10</version>
  <classifier>jdk7</classifier>
</dependency>

Discussion Forum

Conversant Disruptor has a google group so you can follow releases and changes:
https://groups.google.com/forum/#!forum/conversant-disruptor

Extension points exported contracts — how you extend this code

ConcurrentQueue (Interface)
A very high performance blocking buffer, based on Disruptor approach to queues Created by jcairns on 5/28/14. [3 implementers]
src/main/java/com/conversantmedia/util/concurrent/ConcurrentQueue.java
Stack (Interface)
Created by jcairns on 6/11/14. [2 implementers]
src/main/java/com/conversantmedia/util/collection/Stack.java
OptimisticLock (Interface)
Created by jcairns on 2/12/16. [2 implementers]
src/main/java/com/conversantmedia/util/concurrent/OptimisticLock.java
BlockingStack (Interface)
Created by jcairns on 2/16/16. [1 implementers]
src/main/java/com/conversantmedia/util/concurrent/BlockingStack.java

Core symbols most depended-on inside this repo

get
called by 60
src/main/java/com/conversantmedia/util/concurrent/ContendedAtomicInteger.java
size
called by 57
src/main/java/com/conversantmedia/util/collection/Stack.java
add
called by 50
src/main/java/com/conversantmedia/util/estimation/Percentile.java
offer
called by 43
src/main/java/com/conversantmedia/util/concurrent/DisruptorBlockingQueue.java
offer
called by 36
src/main/java/com/conversantmedia/util/concurrent/MPMCBlockingQueue.java
isEmpty
called by 32
src/main/java/com/conversantmedia/util/collection/Stack.java
offer
called by 31
src/main/java/com/conversantmedia/util/concurrent/PushPullBlockingQueue.java
poll
called by 29
src/main/java/com/conversantmedia/util/concurrent/DisruptorBlockingQueue.java

Shape

Method 462
Class 89
Interface 7
Enum 1

Languages

Java100%

Modules by API surface

src/test/java/com/conversantmedia/util/concurrent/DisruptorBlockingQueueTest.java42 symbols
src/main/java/com/conversantmedia/util/concurrent/PushPullBlockingQueue.java36 symbols
src/main/java/com/conversantmedia/util/concurrent/MPMCBlockingQueue.java36 symbols
src/main/java/com/conversantmedia/util/concurrent/DisruptorBlockingQueue.java36 symbols
src/test/java/com/conversantmedia/util/concurrent/PushPullBlockingQueueTest.java35 symbols
src/test/java/com/conversantmedia/util/concurrent/MPMCBlockingQueueTest.java35 symbols
src/main/java/com/conversantmedia/util/concurrent/ConcurrentStack.java25 symbols
src/it/java/com/conversantmedia/util/concurrent/DisruptorPerformanceTest.java22 symbols
src/test/java/com/conversantmedia/util/concurrent/ConcurrentStackTest.java16 symbols
src/it/java/com/conversantmedia/util/concurrent/DisruptorPutTakeStressTest.java16 symbols
src/it/java/com/conversantmedia/util/concurrent/DisruptorOfferPollStressTest.java16 symbols
src/main/java/com/conversantmedia/util/estimation/Percentile.java14 symbols

For agents

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

⬇ download graph artifact