使用管道流构建线程信息通道 | 带你学《Java语言高级特性》之六十二-阿里云开发者社区

开发者社区> Java开发者> 正文

使用管道流构建线程信息通道 | 带你学《Java语言高级特性》之六十二

简介: 在之前学习的几种IO流中不难发现,它们在面对线程间通信问题的时候显然无法实现IO操作,这时需要用到本节介绍的管道流来进行处理。

上一篇:运用内存操作流实现IO操作 | 带你学《Java语言高级特性》之六十一
在之前学习的几种IO流中不难发现,它们在面对线程间通信问题的时候显然无法实现IO操作,这时需要用到本节介绍的管道流来进行处理。

【本节目标】
通过阅读本节内容,你将了解到几种管道流实现类的继承关系及其相关方法的功能,并结合实例代码实现线程间的数据通信工作。

管道流

管道流主要功能是实现两个线程之间的IO处理操作。

image.png
管道流

对于管道流也分为两类:

字节管道流:PipedOutputStream、PipedInputStream
  |- 连接处理:public void connect(PipedInputStream snk) throws IOException;
字符管道流:PipedWriter、PipedReader
  |- 连接处理:public void connect(PipedReader snk) throws IOException;

image.png
PipedOutputStream
image.png
PipedInputStream
image.png
PipedWriter
image.png
PipedReader

范例:实现管道操作

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
 class JavaAPIDemo {
    public static void main(String[] args) throws Exception {
        SendThread send=new SendThread();
        ReceiveThread receive=new ReceiveThread();
        send.getOutput().connect(receive.getInput());//进行管道连接
        new Thread(send,"消息发送线程").start();
        new Thread(receive,"消息接收线程").start();
    }
}
class SendThread implements Runnable{
    private PipedOutputStream output;  //管道输出流

    public SendThread() {
        this.output = new PipedOutputStream();  //实例化管道输出流
    }
    @Override
    public void run() {
        try {    //利用管道实现数据的发送处理
             this.output.write(("【信息发送 - "+Thread.currentThread().getName()+"】www.mldn.cn\n").getBytes());
        }catch (IOException e){
             e.printStackTrace();
        }
        try {
            this.output.close();
        }catch (IOException e){
            e.printStackTrace();
        }
    }
    public PipedOutputStream getOutput(){
        return output;
    }
}
class ReceiveThread implements Runnable{
    private PipedInputStream input;

    public ReceiveThread() {
        this.input = new PipedInputStream();
    }
    @Override
    public void run() {
          byte[] data = new byte[1024];
          int len = 0;
        ByteArrayOutputStream bos = new ByteArrayOutputStream();//所有的数据保存到内存输出流
        try {
             while ((len = input.read(data)) != -1) {
                bos.write(data, 0, len);  //所有的数据保存在内存流里面
            }
            System.out.println("{" +Thread.currentThread().getName()+"接收消息}\n"+ new String(bos.toByteArray()));
            bos.close();
         } catch (IOException e) {
              e.printStackTrace();
         } 
         try {
            this.input.close();
         } catch (IOException e) {
              e.printStackTrace();
         } 
    }
    public PipedInputStream getInput() {
        return input;
    }
}

执行结果:
{消息接收线程接收消息}【信息发送 - 消息发送线程】www.mldn.cn

管道就类似于在医院打点滴的效果,一个负责发送,一个负责接收,中间靠一个管道连接。

想学习更多的Java的课程吗?从小白到大神,从入门到精通,更多精彩不容错过!免费为您提供更多的学习资源。
本内容视频来源于阿里云大学

下一篇:“一目十行”的RandomAccessFile类 | 带你学《Java语言高级特性》之六十三
更多Java面向对象编程文章查看此处

版权声明:本文中所有内容均属于阿里云开发者社区所有,任何媒体、网站或个人未经阿里云开发者社区协议授权不得转载、链接、转贴或以其他方式复制发布/发表。申请授权请邮件developerteam@list.alibaba-inc.com,已获得阿里云开发者社区协议授权的媒体、网站,在转载使用时必须注明"稿件来源:阿里云开发者社区,原文作者姓名",违者本社区将依法追究责任。 如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件至:developer2020@service.aliyun.com 进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
+ 订阅

Java开发者成长课堂

官方博客
官网链接