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.

Author:

Kristian Rosenvold

Constructor Summary

Constructors

Constructor	Description
ThreadedStreamConsumer(EventHandler<Event> target)

Method Summary

Modifier and Type	Method	Description
void	close()
void	handleEvent(Event event)

Methods inherited from class java.lang.Object

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

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