org.jctools.queues.blocking

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>

Constructor Summary

Constructors

Constructor and Description
McParkTakeStrategy()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

McParkTakeStrategy

public McParkTakeStrategy()

Method Detail

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>