Class EventQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.LinkedBlockingQueue<E>

org.eclipse.jetty.toolchain.test.EventQueue<E>

Type Parameters:

E - the type of entry in this EventQueue

All Implemented Interfaces:

Serializable, Iterable<E>, Collection<E>, BlockingQueue<E>, Queue<E>

public class EventQueue<E>
extends LinkedBlockingQueue<E>

Event Queue for capturing potential events within a testing scenario.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
private final Condition	countReached
static final boolean	DEBUG
private static final long	DEBUG_START
private int	goalCount
private final ReentrantLock	lock

Constructor Summary

Constructors

Constructor	Description
EventQueue()

Method Summary

Modifier and Type	Method	Description
boolean	add(E o)
void	awaitEventCount(int expectedEventCount, int timeoutDuration, TimeUnit timeoutUnit)	Await a specific event count
private void	debug(String format, Object... args)
private boolean	goalCheck()
boolean	offer(E o)
void	shutdown()	Shutdown the queue.

Methods inherited from class LinkedBlockingQueue

clear, contains, drainTo, drainTo, forEach, iterator, offer, peek, poll, poll, put, remainingCapacity, remove, removeAll, removeIf, retainAll, size, spliterator, take, toArray, toArray, toString

Methods inherited from class AbstractQueue

addAll, element, remove

Methods inherited from class AbstractCollection

containsAll, isEmpty

Methods inherited from class Object

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

Methods inherited from interface Collection

addAll, containsAll, equals, hashCode, isEmpty, parallelStream, stream, toArray

Methods inherited from interface Queue

element, remove

Field Details

DEBUG

public static final boolean DEBUG

See Also:

• Constant Field Values

DEBUG_START

private static final long DEBUG_START

lock

private final ReentrantLock lock

countReached

private final Condition countReached

goalCount

private int goalCount

Constructor Details

EventQueue

public EventQueue()

Method Details

add

public boolean add(E o)

Specified by:

add in interface BlockingQueue<E>

Specified by:

add in interface Collection<E>

Specified by:

add in interface Queue<E>

Overrides:

add in class AbstractQueue<E>

awaitEventCount

public void awaitEventCount(int expectedEventCount,
 int timeoutDuration,
 TimeUnit timeoutUnit)
                     throws TimeoutException,
InterruptedException

Await a specific event count

Parameters:

expectedEventCount - the number of events to wait for

timeoutDuration - the timeout duration

timeoutUnit - the timeout unit

Throws:

TimeoutException - if timeout while waiting for the event count

InterruptedException - if await was interrupted

debug

private void debug(String format,
 Object... args)

goalCheck

private boolean goalCheck()

offer

public boolean offer(E o)

Specified by:

offer in interface BlockingQueue<E>

Specified by:

offer in interface Queue<E>

Overrides:

offer in class LinkedBlockingQueue<E>

shutdown

public void shutdown()

Shutdown the queue.