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, org.apache.maven.shared.utils.cli.StreamConsumer

public final class ThreadedStreamConsumer
extends Object
implements org.apache.maven.shared.utils.cli.StreamConsumer, Closeable

Knows how to reconstruct *all* the state transmitted over stdout by the forked process.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) final class	ThreadedStreamConsumer.Pumper

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	END_ITEM
private static final int	ITEM_LIMIT_BEFORE_SLEEP
private final BlockingQueue<String>	items
private final ThreadedStreamConsumer.Pumper	pumper
private final AtomicBoolean	stop
private final Thread	thread

Constructor Summary

Constructors

Constructor	Description
ThreadedStreamConsumer(org.apache.maven.shared.utils.cli.StreamConsumer target)

Method Summary

Modifier and Type	Method	Description
void	close()
void	consumeLine(String s)
private boolean	shouldStopQueueing(String 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

END_ITEM

private static final String END_ITEM

See Also:

• Constant Field Values

ITEM_LIMIT_BEFORE_SLEEP

private static final int ITEM_LIMIT_BEFORE_SLEEP

See Also:

• Constant Field Values

items

private final BlockingQueue<String> items

stop

private final AtomicBoolean stop

thread

private final Thread thread

pumper

private final ThreadedStreamConsumer.Pumper pumper

Constructor Details

ThreadedStreamConsumer

public ThreadedStreamConsumer(org.apache.maven.shared.utils.cli.StreamConsumer target)

Method Details

consumeLine

public void consumeLine(String s)

Specified by:

consumeLine in interface org.apache.maven.shared.utils.cli.StreamConsumer

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

shouldStopQueueing

private boolean shouldStopQueueing(String item)

Compared item with END_ITEM by identity.

Parameters:

item - element from items

Returns:

true if tail of the queue