线程通过管道通信

/**
 * 输出线程
 */
public class Writer implements Runnable{
    private PipedOutputStream pipedOutputStream;
    public Writer(PipedOutputStream pipedOutputStream){
        this.pipedOutputStream = pipedOutputStream;
    }
    @Override
    public void run() {
        if(pipedOutputStream!=null){
            //读取控制台信息
            BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
            String content = null;
            try {
                content = reader.readLine();
                String msg = Thread.currentThread().getName()+":"+content;
                pipedOutputStream.write(msg.getBytes(StandardCharsets.UTF_8));
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        //关闭输出流
        try {
            pipedOutputStream.close();
        }catch (Exception e){
           e.printStackTrace();
        }
    }
}

/**
 * reader线程从输入管道中读取数据
 */
public class Reader implements Runnable{
    private PipedInputStream pipedInputStream;
    public Reader(PipedInputStream pipedInputStream) {
        this.pipedInputStream = pipedInputStream;
    }
    @Override
    public void run() {
        if (pipedInputStream != null) {
            String collect = new BufferedReader(new InputStreamReader(pipedInputStream)).lines().collect(Collectors.joining("\n"));
            System.out.println(Thread.currentThread().getName()+":" +collect);
        }
        try {
            pipedInputStream.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

/**
 * 线程间通过管道通信
 */
public class Main {
    public static void main(String[] args) throws IOException {
        //输入管道
        PipedInputStream pipedInputStream = new PipedInputStream();
        //输出管道
        PipedOutputStream pipedOutputStream = new PipedOutputStream();
        //将输出管道和输入管道连接，数据是从输出管道传到输入管道
        pipedOutputStream.connect(pipedInputStream);
        //reader线程持有输入管道
        new Thread(new Reader(pipedInputStream),"reader").start();
        //writer线程持有输出管道
        new Thread(new Writer(pipedOutputStream),"writer").start();
    }
}