如何使用管道流进行流水线作业

如何使用管道流?收藏
新一篇: 自定义事件和事件监听器。。。
如何使用管道流?
       管道是用来将一个线程的输出流信息传送到另一个线程的输入流中。PipedReader 和PipedWriter (和他们类似的输入输出流PipedInputStream  和PipedOutputStream ) 用来实现一个管道的输入和输出， 为什么这是有用的呢?
考 虑到一个类可能实现一系列的多样的处理功能，如排序、反序文本。如果某个方法的输出能够做为另一个方法的输入，以便于可以把一序列的方法的调用串接起来， 那么这样将可以得到高层次的功能。例如，你可以反序list里每个文字的位置，然后对这些文字进行排序，再反序每个文字来创建一个压韵（可能是按字母顺序 的意思）的list。
       如果没有管道流，程序在每一步中只能把当前得到的结果存储在某个临时的位置（比如文件或在内存中）。如下图所示：

    没有管道流，程序必须保存中间结果
        如果有管道流，那么一个方法的输出可以作为下一个要调用的方法的输入，如下图所示：

   通过管道，程序可以把从一个线程传递给另一个。
        让我们来看下这个个程序 RhymingWords，它实现是上图所描述得功能。这个程序用管道连接它的反序和排序方法的输入和输出流来创建一个压韵（可能是按字母顺序的意思）的list。这个程序有几个类组成。
      首先，让我们来看看main方法中反序和排序方法的调用顺序：
FileReader words = new FileReader("words.txt");
Reader rhymingWords = reverse(sort(reverse(words)));
       最里面是调用reverse 方法，并传递一个FileReader对象给它。FileReader对象是打开一个包含一单词列表的文件 words.txt 。reverse 的返回结果传递给sort, sort的返回结果再传递给另一个reverse 方法。
      让我们看下reverse这个方法；sort方法也是类似的，一旦你理解了reverse方法，你自然而然会理解sort方法。
public static Reader reverse(Reader src) throws IOException {
    BufferedReader in = new BufferedReader(src);

    PipedWriter pipeOut = new PipedWriter();
    PipedReader pipeIn = new PipedReader(pipeOut);
    PrintWriter out = new PrintWriter(pipeOut);

    new ReverseThread(out, in).start();

    return pipeIn;
}
    黑体字的语句声明并初始化一个管道的两端-- PipedWriter
和PipedReader-- 通过PipedWriter对象的基础上创建

ipedReader 对象来实现管道的两端的连接。不管往PipedWriter中写入什么，

都能在PipedReader中读取出来。
    管道的连接方法, 如下面的插图所示





     使用PipedWriter 和PipedReader 来构件一个管道.
    reverse 方法通过启动一个 ReverseThread ，把它的输出（output）
写到PipedWriter 然后把PipedReader返回给调用者。 调用者在通过sort
线程，从管道中读取信息.sort方法除了创建和启动一个SortThread 外，
和reverse方法是非常象的。