管道流

在Java語(yǔ)言中提供了各種各樣的輸入/輸出流 Stream ，使我們能夠很方便地對(duì)數(shù)據(jù)進(jìn)行操作，其中管道流是一種特殊的流，用于在不同線程間直接傳送數(shù)據(jù)。一個(gè)線程發(fā)送數(shù)據(jù)到輸出管道流，另一個(gè)線程從輸入管道流中讀取數(shù)據(jù)。

通過使用管道，實(shí)現(xiàn)不同線程間的通信，而無(wú)須借助于類似臨時(shí)文件之類的東西。

字節(jié)流

PipedInputStream 和 PipedOutputStream

字符流

PipedReader 和 PipedWriter

示例

public class PipeStreamTest { public static void main(String[] args) throws IOException, InterruptedException { WriteData writeData = new WriteData(); ReadData readData = new ReadData(); PipedReader reader = new PipedReader(); PipedWriter writer = new PipedWriter(); writer.connect(reader); new Thread(() -> { writeData.writeMethod(writer); }).start(); Thread.sleep(2000); new Thread(() -> { readData.readMethod(reader); }).start(); } static class WriteData { public void writeMethod(PipedWriter writer) { try {System.out.println('write :');for (int i = 0; i < 300; i++) { String outData = '' + (i + 1); writer.write(outData); System.out.print(outData);}System.out.println();writer.close(); } catch (IOException e) {e.printStackTrace(); } } } static class ReadData { public void readMethod(PipedReader reader) { try {System.out.println('read :');char[] byteArray = new char[20];int readLength = reader.read(byteArray);while (readLength != -1) { String newData = new String(byteArray, 0, readLength); System.out.print(newData); readLength = reader.read(byteArray);}System.out.println();reader.close(); } catch (IOException e) {e.printStackTrace(); } } }}

運(yùn)行結(jié)果如下：

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。