管道流PipedInputStream与PipedOutputStream操作实例
2016-06-06 00:38
531 查看
package test.run; /* 管道流: PipedInputStream void connect(PipedOutputStream src) 使此管道输入流连接到管道输出流 src PipedOutputStream void connect(PipedInputStream snk) 在JDK我们看到PipedInputStream中有管道缓冲区,用来接收数据 管道流内部在实现时还有大量的对同步数据的处理 管道输出流和管道输入流执行时不能互相阻塞,所以一般要开启独立线程分别执行 顺便复习了多线程操作 [示例]:管道流 */ import java.io.PipedInputStream; import java.io.PipedOutputStream; class Run { public static void main(String[] args) throws Exception { PipedInputStream pin = new PipedInputStream(); PipedOutputStream pout = new PipedOutputStream(); pin.connect(pout); // 输入流与输出流连接 ReadThread readTh = new ReadThread(pin); WriteThread writeTh = new WriteThread(pout); new Thread(readTh).start(); new Thread(writeTh).start(); } public static void sop(Object obj) // 打印 { System.out.println(obj); } } class ReadThread implements Runnable { private PipedInputStream pin; ReadThread(PipedInputStream pin) // { this.pin = pin; } @Override public void run() // 由于必须要覆盖run方法,所以这里不能抛,只能try { try { sop("R:读取前没有数据,阻塞中...等待数据传过来再输出到控制台..."); byte[] buf = new byte[1024]; int len = pin.read(buf); // read阻塞 sop("R:读取数据成功,阻塞解除..."); String s = new String(buf, 0, len); sop("输出数据"); sop(s); // 将读取的数据流用字符串以字符串打印出来 pin.close(); } catch (Exception e) { throw new RuntimeException("R:管道读取流失败!"); } } public static void sop(Object obj) // 打印 { System.out.println(obj); } } class WriteThread implements Runnable { private PipedOutputStream pout; WriteThread(PipedOutputStream pout) { this.pout = pout; } @Override public void run() { try { sop("W:开始将数据写入:但等个5秒让我们观察..."); Thread.sleep(5000); // 释放cpu执行权5秒 pout.write("W: writePiped 数据...".getBytes()); // 管道输出流 pout.close(); } catch (Exception e) { throw new RuntimeException("W:WriteThread写入失败..."); } } public static void sop(Object obj) // 打印 { System.out.println(obj); } }
相关文章推荐
- tp vendor遇到的坑
- PHP Socket实现websocket(二)Socket函数
- php curl开启方法
- PHP Socket实现websocket(一)基本函数介绍
- php 使用curl模拟登录人人(校内)网的简单实例
- Laravel框架实现发送短信验证功能代码
- PHP编写的图片验证码类文件分享
- thinkphp,onethink和thinkox中验证码不显示的解决方法分析
- PHP session 会话处理函数
- php 解析xml
- ThinkPHP是如何加载系统常量的?
- MySql修改密码后PhpAdmin无法登陆
- phpstorm 2016.1 激活方法
- PHP判断输入数据是否合法常用的类
- php 语言入门
- PHP学习笔记---封装(面向对象三大特性之一)
- php学习第三天----pdo操作
- 数据库config.php文件内容解释及替换方法
- php编程——验证码的实现(session方法)
- yii2分页扩展之实现跳转到具体某页