[javaSE] IO流(管道流)
2023-02-18 15:47:11 时间
之前我们使用io流,都是需要一个中间数组,管道流可以直接输入流对接输出流,一般和多线程配合使用,当读取流中没数据时会阻塞当前的线程,对其他线程没有影响
定义一个类Read实现Runable接口,实现run()方法,构造方法传递PipedInputStream对象
读取流里面的数据
定义一个类Write实现Runable接口,实现run()方法,构造方法传递PipedOutputStream对象
写入流里面数据
获取PipedInputStream对象,new出来
获取PipedOutputStream对象,new出来
调用PipedInputStream对象的connect()方法,对接输出流,参数:PipedOutputStream对象
开启两个线程执行读写
import java.io.IOException; import java.io.PipedInputStream; import java.io.PipedOutputStream; /** * 读取数据线程 * @author taoshihan * */ class ReadPipe implements Runnable{ private PipedInputStream in; public ReadPipe(PipedInputStream in) { this.in=in; } @Override public void run() { System.out.println("开始读取。。。如果没有数据会阻塞"); byte[] b=new byte[1024]; try { int len=in.read(b); String info=new String(b,0,len); in.close(); System.out.println(info); } catch (IOException e) { e.printStackTrace(); } } } /** * 写入数据线程 * @author taoshihan * */ class WritePipe implements Runnable{ private PipedOutputStream out; public WritePipe(PipedOutputStream out) { this.out=out; } @Override public void run() { System.out.println("开始写入。。。延迟5秒"); try { Thread.sleep(5000); out.write("我是数据".getBytes()); out.close(); } catch (Exception e) { e.printStackTrace(); } } } public class PipeDemo { /** * @param args * @throws IOException */ public static void main(String[] args) throws IOException { //连接管道 PipedInputStream in=new PipedInputStream(); PipedOutputStream out=new PipedOutputStream(); in.connect(out); //开启线程 new Thread(new ReadPipe(in)).start(); new Thread(new WritePipe(out)).start(); } }
相关文章
- 视频 | ZYNQ开发板深度评测:高性能FPGA和双核ARM的强强联合!
- I²C协议官方标准文档2021最新版本下载
- 国产FPGA开发板上手体验:不足百元,集成ARM硬核处理器!
- 业内首发!感芯MC3172硬实时RISC-V芯片,还用啥RTOS!
- 从汇率转换通用解决方案到可复用设计思想
- 顶流选手专访 - 最具推广价值作品 - 背后故事
- 顶流选手专访 - 最佳展现创意作品 - 背后故事
- 【精华】顶流选手专访-最佳可视化展现作品(冠军)
- 冠军作品背后的故事会是什么呢
- IBM 人力资源综合分析案例
- 世界五百强财务高管数字化战群雄经典案例
- ZebraBI 6.0 发布,更高更快更强大
- DAX 引擎之父揭秘 DAX 引擎内部细节
- 脑图PPT - 让大脑高效流淌内容
- 融合最佳展现创意的企业智慧经营分析看板
- ArcPy将HDF格式栅格文件批量转为TIFF格式
- 用AvaSpec 2048便携式光谱仪测定地物高光谱曲线
- ArcPy依据成像时间分别批量拼接不同时相的遥感影像
- ArcMap实现栅格遥感影像监督分类
- ENVI实现基于像元的遥感影像镶嵌拼接