Java管道 PipedInputStream PipedOutputStream

PipedInputStream产生用于写入相关 PipedOutputStream的数据，实现管道化概念

PipedOutputStream作为多线程中的数据源，将其与FilterInputStream对象相连以提供有用的接口

管道流的作用体现在：多线程时候任务之间的通信，比如读写数据（IO等），或者生产者消费者任务问题等等

管道输入流应该连接到管道输出流；管道输入流提供要写入管道输出流的所有数据字节。通常，数据由某个线程从

PipedInputStream

对象读取，并由其他线程将其写入到相应的

PipedOutputStream

。不建议对这两个对象尝试使用单个线程，因为这样可能死锁线程。管道输入流包含一个缓冲区，可在缓冲区限定的范围内将读操作和写操作分离开。如果向连接管道输出流提供数据字节的线程不再存在，则认为该管道损坏了

可以将管道输出流连接到管道输入流来创建通信管道。管道输出流是管道的发送端。通常，数据由某个线程写入

PipedOutputStream

对象，并由其他线程从连接的

PipedInputStream

读取。不建议对这两个对象尝试使用单个线程，因为这样可能会造成该线程死锁。如果某个线程正从连接的管道输入流中读取数据字节，但该线程不再处于活动状态，则该管道被视为处于损坏状态

下面例子基本显示了如何使用管道流

package com.xuesong.upc;

import java.io.IOException;

import java.io.PipedInputStream;

import java.io.PipedOutputStream;

class Sender implements Runnable {//我有两个线程，一个用来写数据，另一个用来读数据，两个线程的实现方式略显不同

PipedOutputStream out = new PipedOutputStream();

public PipedOutputStream getPipedOs() {

return out;

}

@Override

public void run() {

// TODO Auto-generated method stub

try {

out.write("hello this is xuesong".getBytes());

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} finally {

try {

out.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

class Receiver extends Thread {

PipedInputStream in = new PipedInputStream();

public PipedInputStream getPipedIs() {

return in;

}

@Override

public void run() {

// TODO Auto-generated method stub

//super.run();

byte[] myByte = new byte[1024];

try {

in.read(myByte);

System.out.println("your information is:"+new String(myByte)

.trim().toUpperCase());

in.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} finally {

//in.close();

}

}

}

public class PipedInputStreamTest {

/**

* @param xuesong

*/

public static void doTestPipe() {

Sender start = new Sender();

Receiver end = new Receiver();

PipedInputStream pis = end.getPipedIs();

PipedOutputStream pos = start.getPipedOs();

try {

pis.connect(pos);

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

start.run();

end.start();

}

public static void main(String[] args) {

// TODO Auto-generated method stub

doTestPipe();

}

}