惠州什么是Java管道？_北大青鸟IT学校

你知道什么是Java管道吗？下面惠州北大青鸟老师给大家分享一下Java管道的知识，希望大家能有收获。

管道连接输入流和输出流。

管道 I/O基于生产者 - 消费者模式，其中生产者产生数据并且消费者消费数据。

在管道 I/O中，我们创建两个流代表管道的两端。 PipedOutputStream对象表示一端，PipedInputStream对象表示另一端。我们使用两个对象上的connect()方法连接两端。

我们还可以通过在创建另一个对象时将一个对象传递给构造函数来连接它们。

以下代码显示了创建和连接管道两端的两种方法：

第一种方法创建管道输入和输出流并连接它们。它使用connect方法连接两个流。

PipedInputStream pis  = new PipedInputStream();
PipedOutputStream pos  = new PipedOutputStream();
pis.connect(pos); /* Connect  the   two  ends  */

第二种方法创建管道输入和输出流并连接它们。它通过将输入管道流传递到输出流构造器来连接两个流。

PipedInputStream pis  = new PipedInputStream();
PipedOutputStream pos  = new PipedOutputStream(pis);

我们可以在连接管道的两端后生成和使用数据。

我们通过使用PipedOutputStream对象的一个write()方法产生数据。无论我们对管道输出流写入什么，自动变得可用于管道输入流对象进行读取。

我们使用PipedInputStream的read()方法从管道读取数据。如果数据在尝试从管道读取时不可用，则管道输入流被阻止。

管道流具有固定容量的缓冲器，以在写入管道和从管道读取之间存储数据。

我们可以设置管道容量，当我们创建它。如果管道的缓冲区已满，则尝试在管道上写入将被阻止。

以下代码创建缓冲区容量为2048字节的管道输入和输出流。

PipedOutputStream pos  = new PipedOutputStream();
PipedInputStream pis  = new PipedInputStream(pos, 2048);

管道用于将数据从一个线程传输到另一个线程。两个线程之间的同步由阻塞读和写来处理。

实例

以下代码演示了如何使用管道 I/O。

import java.io.PipedInputStream;import java.io.PipedOutputStream;public class Main {  public static void main(String[] args) throws Exception {
   PipedInputStream pis = new PipedInputStream();
   PipedOutputStream pos = new PipedOutputStream();
   pos.connect(pis);

   Runnable producer = () -> produceData(pos);
   Runnable consumer = () -> consumeData(pis);    new Thread(producer).start();    new Thread(consumer).start();
 }  public static void produceData(PipedOutputStream pos) {    try {      for (int i = 1; i <= 50; i++) {
       pos.write((byte) i);
       pos.flush();
       System.out.println("Writing: " + i);
       Thread.sleep(500);
     }
     pos.close();
   } catch (Exception e) {
     e.printStackTrace();
   }
 }  public static void consumeData(PipedInputStream pis) {    try {      int num = -1;      while ((num = pis.read()) != -1) {
       System.out.println("Reading: " + num);
     }
     pis.close();
   } catch (Exception e) {
     e.printStackTrace();
   }

 }
}

上面的代码生成以下结果。

Writing:1

Reading:1

Reading:2

Writing:2

Writing:3

Reading:3

Writing:4

Reading:4

Writing:5

Reading:5

想了解更多关于Java的资讯吗？可以来惠州北大青鸟新方舟校区了解一下。

Java

标签：惠州计算机JAVA软件开发惠州计算机Java软件开发惠州计算机JAVA培训惠州计算机JAVA软件开发学校惠州计算机Java软件开发培训JAVAJava软件开发北大青鸟IT计算机学校北大青鸟IT软件学校北大青鸟IT学校