dorkbox/MessageBus
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

renamed queue

Browse Source
This commit is contained in:
nathan 2015-05-01 00:40:28 +02:00
parent 4276f881e8
commit ac4e396f5d
2 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/dorkbox/util/messagebus/common/simpleq/SimpleQueue.java
View File

@ -2,6 +2,7 @@ package dorkbox.util.messagebus.common.simpleq;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import dorkbox.util.messagebus.common.simpleq.jctools.MpmcArrayTransferQueue;
import dorkbox.util.messagebus.common.simpleq.jctools.Pow2; import dorkbox.util.messagebus.common.simpleq.jctools.Pow2;
public final class SimpleQueue { public final class SimpleQueue {
@ -41,17 +42,17 @@ public final class SimpleQueue {
*/ */
static final long spinForTimeoutThreshold = 1000L; static final long spinForTimeoutThreshold = 1000L;
private MpmcExchangerQueue queue; private MpmcArrayTransferQueue queue;
public SimpleQueue(final int size) { public SimpleQueue(final int size) {
this.queue = new MpmcExchangerQueue(Pow2.roundToPowerOfTwo(size)); this.queue = new MpmcArrayTransferQueue(Pow2.roundToPowerOfTwo(size));
} }
/** /**
* PRODUCER * PRODUCER
*/ */
public void put(Object item) throws InterruptedException { public void put(Object item) throws InterruptedException {
this.queue.xfer(item, false, 0, MpmcExchangerQueue.TYPE_PRODUCER); this.queue.xfer(item, false, 0, MpmcArrayTransferQueue.TYPE_PRODUCER);
} }
@ -61,7 +62,7 @@ public final class SimpleQueue {
public Object take() throws InterruptedException { public Object take() throws InterruptedException {
// this.queue.xfer(123, false, 0, MpmcExchangerQueue.TYPE_PRODUCER); // this.queue.xfer(123, false, 0, MpmcExchangerQueue.TYPE_PRODUCER);
// return 123; // return 123;
return this.queue.xfer(null, false, 0, MpmcExchangerQueue.TYPE_CONSUMER); return this.queue.xfer(null, false, 0, MpmcArrayTransferQueue.TYPE_CONSUMER);
} }
private Object xfer(Object item, boolean timed, long nanos, byte incomingType) throws InterruptedException { private Object xfer(Object item, boolean timed, long nanos, byte incomingType) throws InterruptedException {

8
src/main/java/dorkbox/util/messagebus/common/simpleq/MpmcExchangerQueue.java → src/main/java/dorkbox/util/messagebus/common/simpleq/jctools/MpmcArrayTransferQueue.java
View File

@ -1,13 +1,13 @@
package dorkbox.util.messagebus.common.simpleq; package dorkbox.util.messagebus.common.simpleq.jctools;
import static dorkbox.util.messagebus.common.simpleq.jctools.UnsafeAccess.UNSAFE; import static dorkbox.util.messagebus.common.simpleq.jctools.UnsafeAccess.UNSAFE;
import java.util.concurrent.ThreadLocalRandom; import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.locks.LockSupport; import java.util.concurrent.locks.LockSupport;
import dorkbox.util.messagebus.common.simpleq.jctools.MpmcArrayQueueConsumerField; import dorkbox.util.messagebus.common.simpleq.Node;
public final class MpmcExchangerQueue extends MpmcArrayQueueConsumerField<Node> { public final class MpmcArrayTransferQueue extends MpmcArrayQueueConsumerField<Node> {
public static final int TYPE_FREE = 0; public static final int TYPE_FREE = 0;
public static final int TYPE_CONSUMER = 1; public static final int TYPE_CONSUMER = 1;
@ -84,7 +84,7 @@ public final class MpmcExchangerQueue extends MpmcArrayQueueConsumerField<Node>
long p30, p31, p32, p33, p34, p35, p36, p37; long p30, p31, p32, p33, p34, p35, p36, p37;
/** Creates a {@code EliminationStack} that is initially empty. */ /** Creates a {@code EliminationStack} that is initially empty. */
public MpmcExchangerQueue(final int size) { public MpmcArrayTransferQueue(final int size) {
super(size); super(size);
// pre-fill our data structures // pre-fill our data structures