Class AbstractCondition

java.lang.Object

com.conversantmedia.util.concurrent.AbstractCondition

All Implemented Interfaces:

Condition

Direct Known Subclasses:

ConcurrentStack.StackNotEmpty, ConcurrentStack.StackNotFull, DisruptorBlockingQueue.QueueNotEmpty, DisruptorBlockingQueue.QueueNotFull, MPMCBlockingQueue.QueueNotEmpty, MPMCBlockingQueue.QueueNotFull, PushPullBlockingQueue.QueueNotEmpty, PushPullBlockingQueue.QueueNotFull

abstract class AbstractCondition
extends Object
implements Condition

Created by jcairns on 12/11/14.

Field Summary

Fields

Modifier and Type	Field	Description
private final Condition	condition
private final ReentrantLock	queueLock

Fields inherited from interface Condition

MAX_PROG_YIELD, PARK_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
AbstractCondition()

Method Summary

Modifier and Type	Method	Description
void	await()
void	awaitNanos(long timeout)
void	signal()

Methods inherited from class Object

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

Methods inherited from interface Condition

test

Field Details

queueLock

private final ReentrantLock queueLock

condition

private final Condition condition

Constructor Details

AbstractCondition

AbstractCondition()

Method Details

awaitNanos

public void awaitNanos(long timeout)
                throws InterruptedException

Specified by:

awaitNanos in interface Condition

Throws:

InterruptedException

await

public void await()
           throws InterruptedException

Specified by:

await in interface Condition

Throws:

InterruptedException

signal

public void signal()

Specified by:

signal in interface Condition