public class QueueOutputStream extends OutputStream
PipedOutputStream
; queue input stream provides what's written in queue
output stream.
Example usage:
QueueOutputStream outputStream = new QueueOutputStream(); QueueInputStream inputStream = outputStream.newPipeInputStream(); outputStream.write("hello world".getBytes(UTF_8)); inputStream.read();Unlike JDK
PipedInputStream
and PipedOutputStream
, queue input/output streams may be used safely in a
single thread or multiple threads. Also, unlike JDK classes, no special meaning is attached to initial or current
thread. Instances can be used longer after initial threads exited.
Closing a QueueOutputStream
has no effect. The methods in this class can be called after the stream has been
closed without generating an IOException
.
QueueInputStream
Constructor and Description |
---|
QueueOutputStream()
Constructs a new instance with no limit to internal buffer size.
|
QueueOutputStream(BlockingQueue<Integer> blockingQueue)
Constructs a new instance with given buffer.
|
Modifier and Type | Method and Description |
---|---|
QueueInputStream |
newQueueInputStream()
Creates a new QueueInputStream instance connected to this.
|
void |
write(int b)
Writes a single byte.
|
close, flush, write, write
public QueueOutputStream()
public QueueOutputStream(BlockingQueue<Integer> blockingQueue)
blockingQueue
- backing queue for the streampublic QueueInputStream newQueueInputStream()
public void write(int b) throws InterruptedIOException
write
in class OutputStream
InterruptedIOException
- if the thread is interrupted while writing to the queue.Copyright © 2002–2021 The Apache Software Foundation. All rights reserved.