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 com.conversantmedia.util.concurrent.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 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.conversantmedia.util.concurrent.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