Class AbstractWaitingCondition

java.lang.Object

com.conversantmedia.util.concurrent.AbstractWaitingCondition

All Implemented Interfaces:

Condition

Direct Known Subclasses:

ConcurrentStack.WaitingStackNotEmpty, ConcurrentStack.WaitingStackNotFull, DisruptorBlockingQueue.WaitingQueueNotEmpty, DisruptorBlockingQueue.WaitingQueueNotFull, MPMCBlockingQueue.WaitingQueueNotEmpty, MPMCBlockingQueue.WaitingQueueNotFull, PushPullBlockingQueue.WaitingQueueNotEmpty, PushPullBlockingQueue.WaitingQueueNotFull

public abstract class AbstractWaitingCondition
extends Object
implements Condition

Created by jcairns on 12/11/14.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) long	c1
(package private) long	c2
(package private) long	c3
(package private) long	c4
(package private) long	c5
(package private) long	c6
(package private) long	c7
(package private) long	c8
private static final int	CACHE_LINE_REFS
private static final int	MAX_WAITERS
(package private) long	r1
(package private) long	r2
(package private) long	r3
(package private) long	r4
(package private) long	r5
(package private) long	r6
(package private) long	r7
private static final long	WAIT_TIME
private long	waitCache
private final LongAdder	waitCount
private final AtomicReferenceArray<Thread>	waiter
private static final long	WAITER_MASK

Fields inherited from interface Condition

MAX_PROG_YIELD, PARK_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
AbstractWaitingCondition()

Method Summary

Modifier and Type	Method	Description
void	await()
void	awaitNanos(long timeout)
void	signal()
abstract boolean	test()	code below will block until test() returns false

Methods inherited from class Object

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

Field Details

CACHE_LINE_REFS

private static final int CACHE_LINE_REFS

MAX_WAITERS

private static final int MAX_WAITERS

See Also:

• Constant Field Values

WAITER_MASK

private static final long WAITER_MASK

See Also:

• Constant Field Values

WAIT_TIME

private static final long WAIT_TIME

See Also:

• Constant Field Values

waitCount

private final LongAdder waitCount

waiter

private final AtomicReferenceArray<Thread> waiter

r1

long r1

r2

long r2

r3

long r3

r4

long r4

r5

long r5

r6

long r6

r7

long r7

waitCache

private long waitCache

c1

long c1

c2

long c2

c3

long c3

c4

long c4

c5

long c5

c6

long c6

c7

long c7

c8

long c8

Constructor Details

AbstractWaitingCondition

public AbstractWaitingCondition()

Method Details

test

public abstract boolean test()

code below will block until test() returns false

Specified by:

test in interface Condition

Returns:

boolean - true if condition is not satisfied

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