Java I/O系统是建立在数据流概念之上的，在UNIX操作系统中有一个类似的概念很流行，那就是管道，它具有将一个程序的输出当作另一个程序的输入的能力。



Java为这种管道概念提供了PipedInputStream和PipedOutputStream类。将这两者结合在一起，它们允许一个Java组件输出数据到输出流，而另一个组件将这个输出流当作输入流来读取。

举个例子可以说明，比如一个用来记录应用程序日志信息的组件和一个用来显示流数据动态报表的组件。通过给日志记录组件提供PipedOutputStream，给报表组件提供相应的PipedInputStream，这两个组件就不用知道对方的情况而可以相互通信。

最简单的情况下，代码段如下所示：

importjava.io.*;

public class Foo {

static public void main(String[] args) throwsIOException {
PipedOutputStream pout = newPipedOutputStream();
PipedInputStream= new PipedInputStream(pout);
for(int i=0; i 〈 100; i++) {
pout.write((byte)i );
}
pout.close();

int j=0;
while( (j = pin.read()) != -1)
{
System.err.println(j);
}
pin.close();
}
}
上面的代码中，一定要记得调用close()以关闭输出流"pout"，否则第二轮循环永远也不会结束。

这个粗泛的例子并不是正常的可用的代码。随着第一轮循环数量越来越大，PipedOutputStream中的缓冲将会用尽，从而出现问题，比如它在等待某些程序从流里面删除数据时会导致线程死锁。

这就是为什么管道流的Javadoc中声明了PipedInputStream和PipedOutputStream必须用在多线程环境里面的原因。