Class McParkTakeStrategy<E>

java.lang.Object

org.jctools.queues.blocking.McParkTakeStrategy<E>

All Implemented Interfaces:

TakeStrategy<E>

public final class McParkTakeStrategy<E>
extends Object
implements TakeStrategy<E>

Field Summary

Fields

Modifier and Type	Field	Description
private final Object	obj
private long	waiters
private static final AtomicLongFieldUpdater<McParkTakeStrategy>	WAITERS_UPDATER

Constructor Summary

Constructors

Constructor	Description
McParkTakeStrategy()

Method Summary

Modifier and Type	Method	Description
void	signal()
boolean	supportsSpec(ConcurrentQueueSpec qs)
E	waitPoll(Queue<E> q)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

WAITERS_UPDATER

private static final AtomicLongFieldUpdater<McParkTakeStrategy> WAITERS_UPDATER

waiters

private volatile long waiters

obj

private final Object obj

Constructor Details

McParkTakeStrategy

public McParkTakeStrategy()

Method Details

signal

public void signal()

Specified by:

signal in interface TakeStrategy<E>

waitPoll

public E waitPoll(Queue<E> q)
           throws InterruptedException

Specified by:

waitPoll in interface TakeStrategy<E>

Throws:

InterruptedException

supportsSpec

public boolean supportsSpec(ConcurrentQueueSpec qs)

Specified by:

supportsSpec in interface TakeStrategy<E>