玩家一不小心
玩家一不小心
#### Issue details It seems that `reset` should be replaced by `resettask` ```java public void resetAllChildren() { for (int i = 0, n = getChildCount(); i < n; i++) {...
1. For MpscLinkedArrayQueue, producer(producerLimit) rely on consumerIndex. 2. For MpscLinkedArrayQueue, newBuffer is unreachable until soProducerIndex. 3. For SpscLinkedArrayQueue, newBuffer is unreachable until soRefElement(JUMP). 4. Fix resize assertion. 5. For MpscUnboundedXaddArrayQueue,...
This may be a naming error that is confusing. ``` final void soPrev(R value) { UNSAFE.putObject(this, PREV_OFFSET, value); } ```
Just like an object factory, the oldPNode.soNext(head) can ensure correct construction. ``` @Override public int fill(Supplier s, int limit) { if (null == s) throw new IllegalArgumentException("supplier is null"); if...
I implemented my own version of Disruptor with some design improvements. 1. I separated the wait strategy from the blocking wait => SequenceBlocker. 2. Allow consumers to use different waiting...