Java多线程通过管道实现线程间通信

文
章
目
录

• 案例场景
• 管道使用方式
• 代码案例
• 案例1：PipedInputStream和PipedOutputStream
•  案例2：PipedWriter和PipedReader
•  总结

Java多线程场景，线程与线程之间需要通信协作，之前我们讲了两篇文章Java多线程：线程间通信（等待/通知机制）、Java多线程：线程间通信（生产者消费者模式），而我们可以通过管道实现线程间通信。

案例场景

按照用户搜索条件查询数据，并将数据下载到用户本地，那系统通常的做法就是按照用户检索条件查询出结果集，将结果集生成excel表，在将excel表上传到ftp或者oss云盘之类的地方，最后将下载连接发送给用户，最后用户点击链接进行下载，那么使用管道就减少了数据生成到本地，在上传到云盘的工作，直接生成到用户下载，提高用户体验和效率。

管道使用方式

Java.io包的PipeStream管道流用于在线程之间传递数据，一个线程通过管道输出数据，另一个线程从管道中输入数据。相关类包括：

• PipedInputStream
• PipedOutputStream
• PipedReader
• PipedWriter

前两种是基础字节流，后两种是基础字符流。

代码案例

案例1：PipedInputStream和PipedOutputStream

使用PipedInputStream和PipedOutputStream在线程间传递字节流：

public class Test {
    public static void main(String[] args) throws IOException {
        //定义管道字节流
        PipedInputStream in = new PipedInputStream();
        PipedOutputStream out = new PipedOutputStream();
        //建立管道之间的关系
        in.connect(out);

        //创建两个线程，分别往管道里写数据，和读数据
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    writeData(out);
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }, \"Thread1\").start();

        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    readData(in);
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }, \"Thread2\").start();
    }

    //向管道流中写入数据
    public static void writeData(PipedOutputStream out) throws IOException {
        //分别把0～100的数据写入管道
        try {
            for(int i = 0; i <= 100; i++) {
                //把字节数组写入到输出管道流中
                out.write((\"\" + i).getBytes(StandardCharsets.UTF_8));  
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            out.close();
        }
    }

    //从管道流中读取数据
    public static void readData(PipedInputStream in) throws IOException {
        int count = 0;
        byte[] bytes = new byte[1024];
        int len = 0;
        try {
            while((len = in.read(bytes)) != -1) {
                System.out.println(new String(bytes, 0, len));
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            in.close();
        }
    }

}

 案例2：PipedWriter和PipedReader

PipedWriter、PipedReader实现多线程从控制台读取用户输入输出：

public class PipedTeset {
    public static void main(String[] args) throws IOException {
        PipedReader in = new PipedReader();
        PipedWriter out = new PipedWriter();
        out.connect(in);
        Thread printThread = new Thread(new PrintThread(in), \"printThread\");
        printThread.start();
        int receive = 0;
        try {
            while ((receive = System.in.read()) != -1) {
                // 主线程进行读取控制台输入
                out.write(receive);
            }
        } catch (RuntimeException e) {

        }
    }

    static class PrintThread implements Runnable{
        private PipedReader in;

        public PrintThread(PipedReader in) {
            this.in = in;
        }

        @Override
        public void run() {
            int receive;
            try {
                while ((receive = in.read()) != -1){
                    // printThread 收到字符然后输入，这里可以使用sokcet编程将字符传输到对应计算机中
                    System.out.print((char) receive);
                }
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }
    }
}

 总结

以上就是Java多线程通过管道实现线程间通信的全部内容。