通过管道进行线程间通信：字节流。字符流的用法及API类似

package thread.communicate;

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

/*2015-11-19*/
public class CommunicateWithPipedStream {
    public static void main(String[] args) {
        try {
            PipedOutputStream out = new PipedOutputStream();
            DataWriter writer = new DataWriter(out);
            PipedInputStream in = new PipedInputStream();
            DataReader reader = new DataReader(in);
            // out.connect(in);
            in.connect(out);
         new Thread(writer, "Writer").start();
            new Thread(reader, "Reader").start();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }
}

class DataWriter implements Runnable {
    private PipedOutputStream _out;

    public DataWriter(PipedOutputStream out) {
        super();
        this._out = out;
    }

    @Override
    public void run() {
        write();
    }

    public void write() {
        System.out.println(Thread.currentThread() + "Start write....");
        try {
            for (int i = 0; i < 20; i++) {
                String outStr = "" + (i + 1);
                System.out.println(Thread.currentThread() + outStr);
                _out.write(outStr.getBytes());
            }
            _out.close();

        } catch (IOException e) {
            e.printStackTrace();
        }

    }

}

class DataReader implements Runnable {

    private PipedInputStream _in;

    public DataReader(PipedInputStream in) {
        _in = in;
    }

    @Override
    public void run() {
        read();
    }

    public void read() {
        try {
            System.out.println(Thread.currentThread() + "Start read....");
            byte[] byteArray = new byte[20];
            int readLength = _in.read(byteArray);
            while (readLength != -1) {
                String newData = new String(byteArray, 0, readLength);
                System.out.println(Thread.currentThread() + newData);
                readLength = _in.read(byteArray);
            }
            System.out.println();
            _in.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

Thread[Writer,5,main]Start write....
Thread[Writer,5,main]1
Thread[Reader,5,main]Start read....
Thread[Writer,5,main]2
Thread[Reader,5,main]1
Thread[Reader,5,main]2
Thread[Writer,5,main]3
Thread[Writer,5,main]4
Thread[Writer,5,main]5
Thread[Writer,5,main]6
Thread[Writer,5,main]7
Thread[Writer,5,main]8
Thread[Writer,5,main]9
Thread[Writer,5,main]10
Thread[Writer,5,main]11
Thread[Writer,5,main]12
Thread[Writer,5,main]13
Thread[Writer,5,main]14
Thread[Writer,5,main]15
Thread[Writer,5,main]16
Thread[Writer,5,main]17
Thread[Writer,5,main]18
Thread[Writer,5,main]19
Thread[Writer,5,main]20
Thread[Reader,5,main]34567891011121314151
Thread[Reader,5,main]617181920