Java管道流實(shí)現(xiàn)線程間通信過(guò)程解析
管道流
在Java語(yǔ)言中提供了各種各樣的輸入/輸出流 Stream ,使我們能夠很方便地對(duì)數(shù)據(jù)進(jìn)行操作,其中管道流是一種特殊的流,用于在不同線程間直接傳送數(shù)據(jù)。一個(gè)線程發(fā)送數(shù)據(jù)到輸出管道流,另一個(gè)線程從輸入管道流中讀取數(shù)據(jù)。
通過(guò)使用管道,實(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)。
相關(guān)文章:
1. 詳解Android studio 動(dòng)態(tài)fragment的用法2. 解決Android studio xml界面無(wú)法預(yù)覽問(wèn)題3. 圖文詳解vue中proto文件的函數(shù)調(diào)用4. Spring Boot和Thymeleaf整合結(jié)合JPA實(shí)現(xiàn)分頁(yè)效果(實(shí)例代碼)5. php模擬實(shí)現(xiàn)斗地主發(fā)牌6. 什么是python的自省7. Vue封裝一個(gè)TodoList的案例與瀏覽器本地緩存的應(yīng)用實(shí)現(xiàn)8. vue 使用localstorage實(shí)現(xiàn)面包屑的操作9. .Net Core使用Coravel實(shí)現(xiàn)任務(wù)調(diào)度的完整步驟10. Vuex localStorage的具體使用

網(wǎng)公網(wǎng)安備