JAVA的IO编程:管道流
2023-09-14 08:58:42 时间
掌握线程通讯流(管道流)的使用
管道流的主要作用是可以进行两个线程间的通讯,分为管道输入流(PipeOutputStream)和管道输出流(PipeInputStream)。
如果要想进行管道输出,则必须把输出流连在输入流之上,在PipeOutputStream上有如下方法用于连接管道。
void connect(PipedInputStream snk) 将此管道输出流连接到接收者。
要想连接输入和输出,必须使用此方法、
PipeOutputStream输出方法:
void write(byte[] b, int off, int len)
将 len 字节从初始偏移量为 off 的指定 byte 数组写入该管道输出流。
PipeInputStream输入方法:读取文件的方法
将连接的PipeOutputStream对象实例的输入流的数据,通过read方法,把内容读取到数组中。
int read(byte[] b, int off, int len)
将最多 len 个数据字节从此管道输入流读入 byte 数组。
实例代码:
package 类集; import java.io.* ; class Send implements Runnable{ // 线程类 private PipedOutputStream pos = null ; // 管道输出流 public Send(){ this.pos = new PipedOutputStream() ; // 实例化输出流 } public void run(){ String str = "Hello World!!!" ; // 要输出的内容 try{ this.pos.write(str.getBytes()) ; }catch(IOException e){ e.printStackTrace() ; } try{ this.pos.close() ; }catch(IOException e){ e.printStackTrace() ; } } public PipedOutputStream getPos(){ // 得到此线程的管道输出流 return this.pos ; } }; class Receive implements Runnable{ private PipedInputStream pis = null ; // 管道输入流 public Receive(){ this.pis = new PipedInputStream() ; // 实例化输入流 } public void run(){ byte b[] = new byte[1024] ; // 接收内容 int len = 0 ; try{ len = this.pis.read(b) ; // 读取内容 }catch(IOException e){ e.printStackTrace() ; } try{ this.pis.close() ; // 关闭 }catch(IOException e){ e.printStackTrace() ; } System.out.println("接收的内容为:" + new String(b,0,len)) ;//注意,这里是把读入的数组的数据输出,而不是PipeInputStream实例对象输出, } public PipedInputStream getPis(){ return this.pis ; } }; public class PipedDemo{ public static void main(String args[]){ Send s = new Send() ; Receive r = new Receive() ; try{ s.getPos().connect(r.getPis()) ; // 连接管道 }catch(IOException e){ e.printStackTrace() ; } new Thread(s).start() ; // 启动线程 new Thread(r).start() ; // 启动线程 } };
PipeInputStream读取文件后,读取的数据都存在了PipeInputStream对象的实例中,且类型为byte。
总结:
开发中很少直接开发多线程程序,本道程序,只是让读者加深读写的操作过程,了解,线程间如何通讯。
相关文章
- Java高级编程:闭包
- java volatile关键字的作用_Java并发编程彻底搞懂volatile关键字「建议收藏」
- java线程池的面试题_献给准备面试的你,Java线程and线程池面试题小结「建议收藏」
- java 链表长度_Java实现单向链表[通俗易懂]
- 反应java程序并行机制的特点_Java语言具有许多优点和特点,下列选项中能反映Java程序并行机制特点的是()。…[通俗易懂]
- java是面向对象还是面向过程_Java面向对象编程和面向过程编程的区别[通俗易懂]
- java编程软件下载_Ee Java(Java编程软件) V1.1.0 官方版
- Java入门代码_java编程自学网
- java socket详解_Java Socket 编程原理及教程「建议收藏」
- java事务_Java 事务详解[通俗易懂]
- JAVA静态内部类_java静态内部类实例化
- Java Collections.rotate 方法浅析
- Tars-Java网络编程源码分析
- 【错误记录】Java AWT 图形界面编程报错 ( Exception in thread “main“ java.awt.AWTError: BoxLayout can‘t be shared )
- java并发编程(1):Java多线程-基本线程类-基础知识复习笔记
- Java并发编程之Lock详解编程语言
- Java封装MySQL让编程更简单(java封装mysql)
- MySQL封装之Java实现(mysql封装java)
- 使用Java轻松读取Redis数据 – 一步一步指南!(java读取redis)
- 使用Java监听MySQL数据库变化(java监听mysql)
- Java编程实现MySQL数据库连接(java连mysql数据库)
- Linux与Java结合:开启全新的编程之旅(linux java())
- 秘籍学习实现纯Java版Redis(纯java版redis)
- Java编程从Oracle中读取数据(java读取oracle)
- java如何交换这两个变量的值方法介绍