Java管道流實現線程間通信過程解析
管道流
在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(); } } }}
運行結果如下:
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。
相關文章:
1. 解決Android Studio 格式化 Format代碼快捷鍵問題2. php解決注冊并發問題并提高QPS3. 完美解決vue 中多個echarts圖表自適應的問題4. Java使用Tesseract-Ocr識別數字5. JavaEE SpringMyBatis是什么? 它和Hibernate的區別及如何配置MyBatis6. Springboot 全局日期格式化處理的實現7. SpringBoot+TestNG單元測試的實現8. vue實現web在線聊天功能9. 在Chrome DevTools中調試JavaScript的實現10. Python使用urlretrieve實現直接遠程下載圖片的示例代碼
