Java管道流實現(xiàn)線程間通信過程的示例分析

這篇文章主要介紹Java管道流實現(xiàn)線程間通信過程的示例分析，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

創(chuàng)新互聯(lián)建站是一家朝氣蓬勃的網(wǎng)站建設(shè)公司。公司專注于為企業(yè)提供信息化建設(shè)解決方案。從事網(wǎng)站開發(fā)，網(wǎng)站制作，網(wǎng)站設(shè)計，網(wǎng)站模板，微信公眾號開發(fā)，軟件開發(fā)，小程序設(shè)計，十余年建站對成都木制涼亭等多個行業(yè)，擁有多年建站經(jīng)驗。

管道流

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

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

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

運行結(jié)果如下：

Java的優(yōu)點是什么

1. 簡單，只需理解基本的概念，就可以編寫適合于各種情況的應(yīng)用程序；2. 面向?qū)ο螅?. 分布性，Java是面向網(wǎng)絡(luò)的語言；4. 魯棒性，java提供自動垃圾收集來進行內(nèi)存管理，防止程序員在管理內(nèi)存時容易產(chǎn)生的錯誤。；5. 安全性，用于網(wǎng)絡(luò)、分布環(huán)境下的Java必須防止病毒的入侵。6. 體系結(jié)構(gòu)中立，只要安裝了Java運行時系統(tǒng)，就可在任意處理器上運行。7. 可移植性，Java可以方便地移植到網(wǎng)絡(luò)上的不同機器。8.解釋執(zhí)行，Java解釋器直接對Java字節(jié)碼進行解釋執(zhí)行。

以上是“Java管道流實現(xiàn)線程間通信過程的示例分析”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對大家有幫助，更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

當(dāng)前題目：Java管道流實現(xiàn)線程間通信過程的示例分析
本文來源：http://www.muchs.cn/article12/geeegc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供品牌網(wǎng)站設(shè)計、建站公司、網(wǎng)站制作、外貿(mào)網(wǎng)站建設(shè)、商城網(wǎng)站、網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)