public final class ThreadedStreamConsumer
extends java.lang.Object
implements org.apache.maven.shared.utils.cli.StreamConsumer
Modifier and Type | Class and Description |
---|---|
(package private) static class |
ThreadedStreamConsumer.Pumper |
Modifier and Type | Field and Description |
---|---|
private static int |
ITEM_LIMIT_BEFORE_SLEEP |
private java.util.concurrent.BlockingQueue<java.lang.String> |
items |
private static java.lang.String |
POISON |
private ThreadedStreamConsumer.Pumper |
pumper |
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 static final java.lang.String POISON
private static final int ITEM_LIMIT_BEFORE_SLEEP
private final java.util.concurrent.BlockingQueue<java.lang.String> items
private final java.lang.Thread thread
private final ThreadedStreamConsumer.Pumper pumper