Java I/O系统是建立在数据流概念之上的在UNIX操作系统中有一个类似的概念很流行那就是管道它具有将一个程序的输出当作另一个程序的输入的能力
Java为这种管道概念提供了PipedInputStream和PipedOutputStream类将这两者结合在一起它们允许一个Java组件输出数据到输出流而另一个组件将这个输出流当作输入流来读取
举个例子可以说明比如一个用来记录应用程序日志信息的组件和一个用来显示流数据动态报表的组件通过给日志记录组件提供PipedOutputStream给报表组件提供相应的PipedInputStream这两个组件就不用知道对方的情况而可以相互通信
最简单的情况下代码段如下所示
importjavaio*;
public class Foo {
static public void main(String[] args) throwsIOException {
PipedOutputStream pout = newPipedOutputStream();
PipedInputStream= new PipedInputStream(pout);
for(int i=; i 〈 ; i++) {
poutwrite((byte)i );
}
poutclose();
int j=;
while( (j = pinread()) != )
{
Systemerrprintln(j);
}
pinclose();
}
}
上面的代码中一定要记得调用close()以关闭输出流pout否则第二轮循环永远也不会结束
这个粗泛的例子并不是正常的可用的代码随着第一轮循环数量越来越大PipedOutputStream中的缓沖将会用尽从而出现问题比如它在等待某些程序从流里面删除数据时会导致线程死锁
这就是为什么管道流的Javadoc中声明了PipedInputStream和PipedOutputStream必须用在多线程环境里面的原因
