public final class ScParkTakeStrategy<E> extends java.lang.Object implements TakeStrategy<E>
Modifier and Type | Field and Description |
---|---|
int |
storeFence |
private java.util.concurrent.atomic.AtomicReference<java.lang.Thread> |
t |
Constructor and Description |
---|
ScParkTakeStrategy() |
Modifier and Type | Method and Description |
---|---|
void |
signal() |
boolean |
supportsSpec(ConcurrentQueueSpec qs) |
E |
waitPoll(java.util.Queue<E> q) |
public volatile int storeFence
private java.util.concurrent.atomic.AtomicReference<java.lang.Thread> t
public void signal()
signal
in interface TakeStrategy<E>
public E waitPoll(java.util.Queue<E> q) throws java.lang.InterruptedException
waitPoll
in interface TakeStrategy<E>
java.lang.InterruptedException
public boolean supportsSpec(ConcurrentQueueSpec qs)
supportsSpec
in interface TakeStrategy<E>