JavaIO PipedReader 和 PipedWriter详细讲解及使用实例分析
时间:2018-09-13
本文章向大家介绍JavaIO PipedReader 和 PipedWriter详细讲解及使用实例分析,需要的朋友可以参考一下
功能简介
还记得PipedInputStream 和 PipedOutputStream么
我们之前是这么说的:
使用管道通信时,必须将PipedOutputStream和PipedInputStream配套使用 |
大致流程: 我们在线程A中向PipedOutputStream中写入数据,这些数据会自动的发送到与PipedOutputStream对应的PipedInputStream中,进而存储在PipedInputStream的缓冲中; 线程B通过读取PipedInputStream中的数据 |
对照到我上面画的图就是这样: |
PipedReader PipedWriter 基本原理和工作流程 |
PipedWriter中有一个 PipedReader sink成员变量
PipedReader 中有一个缓冲区char buffer[] 可以用于保存数据
他们本质上操作的都是这个缓冲区
PipedReader操作的自己的缓冲区
PipedWriter 操作的是PipedReader 的缓冲区
PipedWriter 需要和PipedReader进行连接,或者在构造的时候直接连接
连接之后,就形成了一个管道 (其实就是PipedWriter 内部可以调用PipedReader 的方法)
PipedWriter 写入的数据,可以通过PipedReader 进行读取
|
构造方法
PipedReader 在构造的时候可以指定缓冲区大小,不指定则使用默认值
也可以在构造的时候就连接到一个PipedWriter 或者后续再连接
所以构造方法有四种形式
其他方法
connect
connect方法,根本形式只有一种 不管是PipedWriter连接PipedReader 还是 PipedReader 连接 PipedReader |
首先真正的将PipedReader和PipedWriter进行连接,也就是设置sink 然后就是设置in和out 他们是写入PipedReader中的缓冲区和从缓冲区读取的索引号 然后就是标志已经连接成功了 |
除了上面介绍的方法以外,就是常规的Reader 和 Writer方法了,他们的语义不变
PipedReader 提供了两个版本的read方法 读取一个字符 或者读取指定个数的字符数目 保存到指定的数组,到她的指定的位置 public synchronized int read() throws IOException public synchronized int read(char cbuf[], int off, int len) throws IOException |
PipedReader 也提供了常规的close方法
PipedWriter 也提供了常规的close 和 flush方法
总结
对于PipedReader和PipedWriter 要理解根本原理
PipedReader内部维护了一个缓冲区 PipedWriter 内部包含了一个PipedWriter类型的引用
PipedWriter通过连接 与 PipedReader相连,也就是获得PipedWriter对象
然后PipedWriter的write也是通过PipedReader 操作缓冲区
PipedReader 也是操作他自己内部的缓冲区
这就实现了 数据的直连
本文说的并没有PipeInputStream和PipedOutputStream中介绍的详细
如果不明白,建议看看之前的PipeInputStream和PipedOutputStream 的介绍
只要彻底理解了管道的原理,通过构造方法成功构造出来管道之后
就可以忘掉这些,权当做他们仅仅就是Writer 和 Reader
- 用深度学习硬件的闲置时间,来挖比特币
- 深度学习:如何理解tensorflow文本蕴含的原理
- 重磅!腾讯与科大讯飞技术共创,Google ProtoBuf进入TARS家族!
- 深度学习与R语言
- 在Keras中展示深度学习模式的训练历史记录
- 分析漏洞利用工具包 Archie和Astrum工具包
- 手游热更新方案xLua开源:Unity3D下Lua编程解决方案
- 如何为Keras中的深度学习模型建立Checkpoint
- Dubbo 源码解析 —— Zookeeper 创建节点
- 熔断器 Hystrix 源码解析 —— 断路器 HystrixCircuitBreaker
- 源码级别解读 mybatis 插件
- 在WebKit中并行加载外部脚本译:
- 100行代码,搞定http监控框架
- 【腾讯反病毒实验室】深度剖析APT28最新作品
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- Tomcat, Jre 证书相关
- zookeeper集群搭建
- Maven Jar包制作与上传及基本使用
- 当你在`bind 0.0.0.0`的时候,你实际在做什么
- Hadoop Hive Hbase Kylin 环境搭建
- Spring MVC 学习
- RSeQC判断链特异性(strand-specific)
- bigWigMerge合并bigwig文件
- WPF桌面开发集成Nginx服务器
- chrome浏览器拦截(block)特定网站某些请求的方法
- 聊一聊:一道 Promise 链式调用的题目
- linux编译运行c++程序
- Python的运算符 (下)
- 深入理解JVM(③)Java的锁优化
- Spring 基于 Java 的配置 - 如何不用Beans.xml照样描述bean之间的依赖关系