久久r热视频,国产午夜精品一区二区三区视频,亚洲精品自拍偷拍,欧美日韩精品二区

您的位置:首頁技術文章
文章詳情頁

Java管道流實現線程間通信過程解析

瀏覽:58日期:2022-09-04 09:58:49

管道流

在Java語言中提供了各種各樣的輸入/輸出流 Stream ,使我們能夠很方便地對數據進行操作,其中管道流是一種特殊的流,用于在不同線程間直接傳送數據。一個線程發送數據到輸出管道流,另一個線程從輸入管道流中讀取數據。

通過使用管道,實現不同線程間的通信,而無須借助于類似臨時文件之類的東西。

字節流

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(); } } }}

運行結果如下:

Java管道流實現線程間通信過程解析

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。

標簽: Java
相關文章:
主站蜘蛛池模板: 崇州市| 新晃| 金阳县| 洛浦县| 武义县| 哈密市| 临西县| 鸡西市| 屯留县| 襄垣县| 合江县| 苏尼特左旗| 无极县| 化隆| 贵德县| 青海省| 东乡族自治县| 昌吉市| 长岭县| 且末县| 西乌珠穆沁旗| 合作市| 大田县| 灵石县| 黄冈市| 池州市| 德阳市| 星座| 胶南市| 名山县| 大港区| 奈曼旗| 涡阳县| 卢湾区| 遂昌县| 盱眙县| 于田县| 蕉岭县| 德阳市| 常熟市| 蒙自县|