disruptor

disruptor copied to clipboard

ProcessingSequenceBarrier.java ```java public long waitFor(final long sequence) throws AlertException, InterruptedException, TimeoutException { checkAlert(); long availableSequence = waitStrategy.waitFor(sequence, cursorSequence, dependentSequence, this); if (availableSequence < sequence) { return availableSequence; } return sequencer.getHighestPublishedSequence(sequence,...

Yegezw

**Describe the bug** With many producers and a blocking wait strategy, `SequenceBarrier.waitForSequence(nextSequence)` can return a value less than its input. Specifically, it can return `nextSequence - 1`. **To Reproduce** Run...

tibco-jufernan

BlockingWaitStrategy CPU 100%

2

### I used BlockingWaitStrategy in my code,it makes my project use CPU 100% I use it for exception alert.Our system tps is not high,Fewer exceptions. As you know,I didn't use...

QinZhiWenXuan

please guide me,thanks.

1

https://github.com/LMAX-Exchange/disruptor/blob/109e2881fa421ceac31c7aabc3b96bfd2a94587d/src/main/java/com/lmax/disruptor/SingleProducerSequencer.java#L102 What case will run this code “cachedGatingSequence > current” ? Could Consumer's sequence be more than Producer's sequence ? But this case can be possible ?

dpf371

A service creates multiple Disruptors

5

**Desktop (please complete the following information):** - OS: [win10] - Version [e.g. 3.4.4] - JVM Version [1.8.0_221] **Additional context**     Can I use Disruptor like this, and...

wangshilong1996

Is there a performance problem with the next(n) method？

3

In the next(n) method we used `long wrapPoint = nextSequence - bufferSize;wrapPoint > cachedGatingSequence` in determining whether a wrap occurred or not.For example, in the following figure: Let's say we've...

chenggwang

fix: Message loss

1

Fix the issue where messages are lost if a consumer that is processing an event is killed.

2498298782Zql

Description In version 3.3.6, dynamically removing a consumer thread that is currently processing a message can result in message loss. This issue occurs because the consumer thread might be terminated...

2498298782Zql

how to use threadpool with latest version disruptor

2

zys864

Tech-paper typo: missed footnote; and some rumbling

1

https://lmax-exchange.github.io/disruptor/disruptor.html  Ooops. ---- Also, could you a bit extend the tech paper on cache contention and on the multiple (and variable number) both consumers and producers, and why you...

the-Arioch