Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
48 changed files
with
4,473 additions
and
21 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
101 changes: 101 additions & 0 deletions
101
jctools-core/src/main/java/org/jctools/queues/atomic/unpadded/AtomicQueueUtil.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,101 @@ | ||
| package org.jctools.queues.atomic.unpadded; | ||
|
|
||
| import java.util.concurrent.atomic.AtomicLongArray; | ||
| import java.util.concurrent.atomic.AtomicReferenceArray; | ||
|
|
||
| final class AtomicQueueUtil | ||
| { | ||
| static <E> E lvRefElement(AtomicReferenceArray<E> buffer, int offset) | ||
| { | ||
| return buffer.get(offset); | ||
| } | ||
|
|
||
| static <E> E lpRefElement(AtomicReferenceArray<E> buffer, int offset) | ||
| { | ||
| return buffer.get(offset); // no weaker form available | ||
| } | ||
|
|
||
| static <E> void spRefElement(AtomicReferenceArray<E> buffer, int offset, E value) | ||
| { | ||
| buffer.lazySet(offset, value); // no weaker form available | ||
| } | ||
|
|
||
| static void soRefElement(AtomicReferenceArray buffer, int offset, Object value) | ||
| { | ||
| buffer.lazySet(offset, value); | ||
| } | ||
|
|
||
| static <E> void svRefElement(AtomicReferenceArray<E> buffer, int offset, E value) | ||
| { | ||
| buffer.set(offset, value); | ||
| } | ||
|
|
||
| static int calcRefElementOffset(long index) | ||
| { | ||
| return (int) index; | ||
| } | ||
|
|
||
| static int calcCircularRefElementOffset(long index, long mask) | ||
| { | ||
| return (int) (index & mask); | ||
| } | ||
|
|
||
| static <E> AtomicReferenceArray<E> allocateRefArray(int capacity) | ||
| { | ||
| return new AtomicReferenceArray<E>(capacity); | ||
| } | ||
|
|
||
| static void spLongElement(AtomicLongArray buffer, int offset, long e) | ||
| { | ||
| buffer.lazySet(offset, e); | ||
| } | ||
|
|
||
| static void soLongElement(AtomicLongArray buffer, int offset, long e) | ||
| { | ||
| buffer.lazySet(offset, e); | ||
| } | ||
|
|
||
| static long lpLongElement(AtomicLongArray buffer, int offset) | ||
| { | ||
| return buffer.get(offset); | ||
| } | ||
|
|
||
| static long lvLongElement(AtomicLongArray buffer, int offset) | ||
| { | ||
| return buffer.get(offset); | ||
| } | ||
|
|
||
| static int calcLongElementOffset(long index) | ||
| { | ||
| return (int) index; | ||
| } | ||
|
|
||
| static int calcCircularLongElementOffset(long index, int mask) | ||
| { | ||
| return (int) (index & mask); | ||
| } | ||
|
|
||
| static AtomicLongArray allocateLongArray(int capacity) | ||
| { | ||
| return new AtomicLongArray(capacity); | ||
| } | ||
|
|
||
| static int length(AtomicReferenceArray<?> buf) | ||
| { | ||
| return buf.length(); | ||
| } | ||
|
|
||
| /** | ||
| * This method assumes index is actually (index << 1) because lower bit is used for resize hence the >> 1 | ||
| */ | ||
| static int modifiedCalcCircularRefElementOffset(long index, long mask) | ||
| { | ||
| return (int) (index & mask) >> 1; | ||
| } | ||
|
|
||
| static int nextArrayOffset(AtomicReferenceArray<?> curr) | ||
| { | ||
| return length(curr) - 1; | ||
| } | ||
|
|
||
| } |
Oops, something went wrong.