Package org.apache.maven.plugin.surefire.booterclient.output

Class ThreadedStreamConsumer

java.lang.Object

org.apache.maven.plugin.surefire.booterclient.output.ThreadedStreamConsumer

All Implemented Interfaces:

Closeable, AutoCloseable, EventHandler<Event>

public final class ThreadedStreamConsumer
extends Object
implements EventHandler<Event>, Closeable

Knows how to reconstruct *all* the state transmitted over Channel by the forked process.
After applying the performance improvements with ThreadedStreamConsumer.QueueSynchronizer the throughput becomes 6.33 mega messages per second (158 nano seconds per message, 5 million messages within 0.79 seconds - see the test ThreadedStreamConsumerTest) on CPU i5 Dual Core 2.6 GHz and Oracle JDK 11.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	ThreadedStreamConsumer.FinalEvent
(package private) final class	ThreadedStreamConsumer.Pumper
(package private) static class	ThreadedStreamConsumer.QueueSynchronizer<T>	This synchronization helper mostly avoids the locks.

Field Summary

Fields

Modifier and Type	Field	Description
private final Thread	consumer
private static final Event	END_ITEM
private final AtomicBoolean	isAlive
private final ThreadedStreamConsumer.Pumper	pumper
private static final int	QUEUE_MAX_ITEMS
private final AtomicBoolean	stop
private final ThreadedStreamConsumer.QueueSynchronizer<Event>	synchronizer

Constructor Summary

Constructors

Constructor	Description
ThreadedStreamConsumer(EventHandler<Event> target)

Method Summary

Modifier and Type	Method	Description
void	close()
void	handleEvent(Event event)
private static boolean	shouldStopQueueing(Event item)	Compared item with END_ITEM by identity.

Methods inherited from class java.lang.Object

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

Field Details

QUEUE_MAX_ITEMS

private static final int QUEUE_MAX_ITEMS

See Also:

• Constant Field Values

END_ITEM

private static final Event END_ITEM

synchronizer

private final ThreadedStreamConsumer.QueueSynchronizer<Event> synchronizer

stop

private final AtomicBoolean stop

isAlive

private final AtomicBoolean isAlive

consumer

private final Thread consumer

pumper

private final ThreadedStreamConsumer.Pumper pumper

Constructor Details

ThreadedStreamConsumer

public ThreadedStreamConsumer(EventHandler<Event> target)

Method Details

handleEvent

public void handleEvent(@Nonnull
 Event event)

Specified by:

handleEvent in interface EventHandler<Event>

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

shouldStopQueueing

private static boolean shouldStopQueueing(Event item)

Compared item with END_ITEM by identity.

Parameters:

item - element from items

Returns:

true if tail of the queue