public final class ThreadedStreamConsumer
extends java.lang.Object
implements org.apache.maven.shared.utils.cli.StreamConsumer, java.io.Closeable
Modifier and Type | Class and Description |
---|---|
(package private) class |
ThreadedStreamConsumer.Pumper |
Modifier and Type | Field and Description |
---|---|
private static java.lang.String |
END_ITEM |
private static int |
ITEM_LIMIT_BEFORE_SLEEP |
private java.util.concurrent.BlockingQueue<java.lang.String> |
items |
private ThreadedStreamConsumer.Pumper |
pumper |
private java.util.concurrent.atomic.AtomicBoolean |
stop |
private java.lang.Thread |
thread |
Constructor and Description |
---|
ThreadedStreamConsumer(org.apache.maven.shared.utils.cli.StreamConsumer target) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
consumeLine(java.lang.String s) |
private boolean |
shouldStopQueueing(java.lang.String item)
Compared item with
END_ITEM by identity. |
private static final java.lang.String END_ITEM
private static final int ITEM_LIMIT_BEFORE_SLEEP
private final java.util.concurrent.BlockingQueue<java.lang.String> items
private final java.util.concurrent.atomic.AtomicBoolean stop
private final java.lang.Thread thread
private final ThreadedStreamConsumer.Pumper pumper
public ThreadedStreamConsumer(org.apache.maven.shared.utils.cli.StreamConsumer target)
public void consumeLine(java.lang.String s)
consumeLine
in interface org.apache.maven.shared.utils.cli.StreamConsumer
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
private boolean shouldStopQueueing(java.lang.String item)
END_ITEM
by identity.item
- element from items
true
if tail of the queue