Class ThreadedStreamConsumer.QueueSynchronizer<T>

java.lang.Object
org.apache.maven.plugin.surefire.booterclient.output.ThreadedStreamConsumer.QueueSynchronizer<T>
Type Parameters:
T - element type in the queue
Enclosing class:
ThreadedStreamConsumer

static class ThreadedStreamConsumer.QueueSynchronizer<T> extends Object
This synchronization helper mostly avoids the locks. If the queue size has reached zero or maxQueueSize then the threads are locked (parked/unparked). The thread instance T1 is reader (see the class "Pumper") and T2 is the writer (see the method "handleEvent").