Java管道流實(shí)現(xiàn)線程間通信過程解析
更新時(shí)間：2020年03月20日 11:28:18 作者：lkc9
這篇文章主要介紹了Java管道流實(shí)現(xiàn)線程間通信過程解析,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
管道流
在Java語言中提供了各種各樣的輸入/輸出流 Stream ，使我們能夠很方便地對(duì)數(shù)據(jù)進(jìn)行操作，其中管道流是一種特殊的流，用于在不同線程間直接傳送數(shù)據(jù)。一個(gè)線程發(fā)送數(shù)據(jù)到輸出管道流，另一個(gè)線程從輸入管道流中讀取數(shù)據(jù)。
通過使用管道，實(shí)現(xiàn)不同線程間的通信，而無須借助于類似臨時(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é)果如下：
以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
關(guān)于springboot 配置date字段返回時(shí)間戳的問題
這篇文章主要介紹了springboot 配置date字段返回時(shí)間戳的問題,在springboot2.0后，spring會(huì)將Date字段自動(dòng)給轉(zhuǎn)成UTC字符串了（在沒有配置的情況下），所以date需要轉(zhuǎn)換成時(shí)間戳還是yyyy-MM-dd HH:mm:ss，具體解決方法跟隨小編一起看看吧2021-07-07
postman中實(shí)現(xiàn)傳遞@RequestBody參數(shù)
這篇文章主要介紹了postman中實(shí)現(xiàn)傳遞@RequestBody參數(shù)，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-10-10
關(guān)于Spring Boot對(duì)jdbc的支持問題
這篇文章主要介紹了關(guān)于Spring Boot對(duì)jdbc的支持問題,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-04-04
SpringBoot集成geodesy實(shí)現(xiàn)距離計(jì)算功能
Geodesy：大地測(cè)量學(xué)的神奇力量 Geodesy,又稱大地測(cè)量學(xué),是一門研究地球形狀、大小及其重力場的學(xué)科,在地球距離計(jì)算中,它扮演著至關(guān)重要的角色,故本文給大家介紹了SpringBoot集成geodesy實(shí)現(xiàn)距離計(jì)算功能,感興趣的朋友可以參考下2024-06-06
詳解Java合并數(shù)組的兩種實(shí)現(xiàn)方式
這篇文章主要介紹了Java合并數(shù)組的兩種實(shí)現(xiàn)方式，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-04-04
Spring Boot + thymeleaf 實(shí)現(xiàn)文件上傳下載功能
最近同事問我有沒有有關(guān)于技術(shù)的電子書，我打開電腦上的小書庫，但是郵件發(fā)給他太大了，公司又禁止用文件夾共享，于是花半天時(shí)間寫了個(gè)小的文件上傳程序，部署在自己的Linux機(jī)器上,需要的朋友可以參考下2018-01-01
Java基礎(chǔ)之Integer使用的注意事項(xiàng)及面試題
這篇文章主要給大家介紹了關(guān)于Java基礎(chǔ)之Integer使用注意事項(xiàng)及面試題的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。2017-12-12
這篇文章主要介紹了java8的stream如何取max問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-03-03
Java啟動(dòng)參數(shù)(-,?-X,?-XX參數(shù))的使用
本文主要介紹了Java啟動(dòng)參數(shù)(-,?-X,?-XX參數(shù))的使用，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-06-06
本文主要講解java 線程創(chuàng)建多線程的知識(shí)，這里對(duì)java線程的創(chuàng)建做了詳細(xì)介紹，并附簡單示例代碼，有興趣的小伙伴可以參考下2016-09-09