前言

在并发编程中，需要处理两个问题：线程之间如何通信及线程之间如何同步。通知是指线程之间以何种机制来交换信息。在命令式编程中，线程之间的通信机制有两种：共享内存和消息传递。

在共享内存的并发模型里，线程之间共享程序的公共状态，通过写-读内存中的公共状态进行隐式通信。而子啊消息传递的并发模型里，线程之间没有公共状态，线程之间必须通过发送消息来显式进行通信。

Java 的并发才作用的是共享内存模型，Java线程之间的通信总是隐式进行，整个通信过程对程序员完全透明。

而Java中还有另一种用的比较少的线程间的通信方式：管道流。

如何使用？

管道输入/输入流和普通的文件输入/输出流或者网络输入/输出流不同之处在于，它主要用于线程之间的数据传输，而传输的媒介为内存。

管道输入/输入流主要包括了如下4种具体实现：PipedOutputStream，PipedInputStream，PipedReader 和 PipedWriter，前两种面向字节，而后两种面向字符。

我们先来一个例子看看：

public class PipedStreamDemo {public static void main(String[] args) throws IOException {PipedWriter writer = new PipedWriter();PipedReader reader = new PipedReader();PipedInputStream inputStream = new PipedInputStream();PipedOutputStream outputStream = new PipedOutputStream();// 将输出流和输入流连接writer.connect(reader);Thread printThread = new Thread(new Print(reader));printThread.start();int receive;try {while ((receive = System.in.read()) != -1) {// 从main线程写到 print 线程writer.write(receive);}} finally {writer.close();}}static class Print implements Runnable {private PipedReader in;public Print(PipedReader in) {this.in = in;}@Overridepublic void run() {int receive;try {while ((receive = in.read()) != -1) {// 读取 main 线程发送过来的数据并打印System.out.print((char) receive);}} catch (Exception e) {e.printStackTrace();}}}}

上面的代码种，创建了 printThread，它用来接受 main 线程的输入，任何 main 线程的输入均通过 PipedWriter 写入，而 printThread 在另一端通过 PipedReader 将内容读出并打印。

对于 Piped 类型的流，必须先要进行绑定，也就是调用 connect 方法，如果没有将输入 / 输出流绑定起来，对于该流的访问将会抛出异常。

而作为这两个类连接的重要方法 connect 方法式如何实现的呢？

    public synchronized void connect(PipedReader snk) throws IOException {if (snk == null) {throw new NullPointerException();} else if (sink != null || snk.connected) {throw new IOException("Already connected");} else if (snk.closedByReader || closed) {throw new IOException("Pipe closed");}sink = snk;snk.in = -1;snk.out = 0;snk.connected = true;}

首先参数判断，然后将输入流设置为输出流的 sink 属性。这样就将两个流关联了起来。实现了两个线程的通信。

总结

总的来说，该类的应用场景并不是很多，只是我们应该知道另一种线程通信的方式。嗯，就酱。

good luck ！！！！