使用PipedInputStream类与PipedOutputStream类学习管道流之间的通信
前言
在应用程序中使用PipedInputStream类与PipedOutputStream类来创建管道之间的通信,一个PipedInputStream实例化对象和一个PipedOutputStream实例化对象进行连接产生一个通信管道。PipedInputStream用来从管道中读取写入的数据,PipedOutputStream是向管道中写入数据。通过线程之间的通信使用PipedInputStream类与PipedOutputStream类。使用PipedInputStream类与PipedOutputStream类学习管道流之间的通信。接下来小编带大家一起来学习!
一、PipedInputStream类
1.PipedInputStream类管道输入流,它是可以连接管道输出流,管道输入流提供了要写入管道输出流的所有数据的字节。
2.PipedInputStream类构造方法:
(1)public PipedInputStream():创建管道输入流对象,这个对象它尚未连接。
(2)public PipedInputStream(PipedOutputStream out):创建一个管道输入流,它被连接到参数out指定的管道输出流。如下所示:
PipedInputStream pis=new PipedInputStream();
3.PipedInputStream类方法有:
(1)int read():读取数据的下一个字节。
(2)int read(byte []b,int off,int len):读取len个字节数据到一个字节数组,off参数表示偏移量,len表示读取数据的长度。
(3)void receive(int b):接受一个字节的数据。
(4)void connect(PipedOutputStream src):表示管道输入流连接到管道输出流src
(5)int available():表示没有什么阻碍从输入流中读取字节数。
(6)void close():表示关闭流。
二、PipedOutputStream类
1.PipedOutputStream类是管道输出流,它是可以用于向管道中写入数据。
2.PipedOutputStream类构造方法:
(1)public PipedOutputStream():创建管道输出流对象,这个对象它尚未连接。
(2)public PipedOutputStream(PipedInputStream in):创建一个管道输出流,它被连接到参数in指定的管道输入流。如下所示:
PipedOutputStream pos=new PipedOutputStream();
3.PipedOutputStream类方法有:
(1)void close():表示关闭流。
(2)void connect(PipedInputStream snk):表示管道输出流连接到管道输入流中。
(3)void flush():刷新输出流并强制的写出任何缓冲的输出字节。
(4)void write(int b):写入指定字节到管道输出流。
(5)void write(byte [] b,int off,int len):写入len个字节的指定字节数组从偏移量off开始到管道输出流。
三、使用PipedInputStream类与PipedOutputStream类学习管道流之间的通信案例
1.代码实现:
import java.io.*;
public class P22 {
public static void main(String[] args) throws Exception {
//创建PipedInputStream对象
final PipedInputStream in=new PipedInputStream();
final PipedOutputStream out=new PipedOutputStream();
//两个类进行连接
in.connect(out);
new Thread(new Runnable(){
public void run(){
BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
//通过键盘读取数据写入管道流
PrintStream ps=new PrintStream(out);
System.out.print(Thread.currentThread().getName()+"请输入内容:");
try {
ps.println(br.readLine());
} catch (IOException e) {
e.printStackTrace();
}
}
},"发送数据的线程").start();
new Thread(new Runnable(){
public void run(){
BufferedReader br=new BufferedReader(new InputStreamReader(in));
try {
System.out.println(Thread.currentThread().getName()+"收到的内容:"+br.readLine());
} catch (IOException e) {
e.printStackTrace();
}
}
},"接受数据的线程").start();
}
}
运行的结果如下图所示:
上面代码中使用一个PipedInputStream对象和一个PipedOutputStream对象进行连接产生一个通信管道。,写两个线程,一个线程用于键盘输入的数据管道输出流,另一个线程用来管道读取写入的数据。使用这两个类来实现线程之间的通信。
四、总结
本文主要介绍了PipedInputStream类、PipedOutputStream类、使用PipedInputStream类与PipedOutputStream类学习管道流之间的通信。PipedInputStream类管道输入流,它是可以连接管道输出流,管道输入流提供了要写入管道输出流的所有数据的字节。PipedInputStream介绍了它的构造方法和方法。PipedOutputStream类是管道输出流,它是可以用于向管道中写入数据。PipedOutputStream介绍了它的构造方法和方法。使用PipedInputStream类与PipedOutputStream类学习管道流之间的通信。希望大家通过本文的学习,对你有所帮助!
我是Java进阶者,希望大家通过本文的学习,对你有所帮助!
相关文章
- 发现 Linux SpaceFM 文件管理器的威力
- 夯实数据智能底座 共筑数字经济发展“新基石”
- 五分钟教你使用console.log发布公司的招聘信息
- 微软发布 Windows 11 Beta 预览版 Build 22621.1250 和 22623.1250 (KB5023008)
- Windows 11 学院:在 Windows 11 Build 25290 上如何为文件管理器启用标签页拖拽支持
- 微软Windows 11 Dev 预览版 Build 25290 发布:带来新的开始菜单提醒角标
- 微软正用全屏通知提醒 Windows 10 用户免费升级 Windows 11,要点击 5 次才能退出
- Linux Mint 21.2 将于 6 月发布:改进登录屏幕,优化 Pix 图像管理程序等等
- 字节面试也会问SPI机制?
- 微软正式停售 Windows 10 产品密钥 / 许可证:继续提供 ISO 镜像下载,推荐用户升级 Windows 11
- 用复古电脑程序 Toy CPU 学习低级编程
- Windows 11 新功能泄露:现代音量合成器、实验工具和新的文件管理器
- 微软 Windows 11 文件资源管理器全新设计曝光:UI 迎来大修,整合 Microsoft 365
- 对比Pandas,学习PySpark大数据处理
- 微软宣布为Windows 11 21H2设备开启自动更新到22H2版本
- 互联网都在说降本增效,小红书技术团队是怎么做的?
- 微软将继续提供 Windows 10 ISO 镜像下载,即将停售产品密钥 / 许可证
- 微软宣布为Windows 11 21H2 设备开启自动更新到 22H2 版本
- 面试突击:Properties和Yml有什么区别?
- 微软 Windows 11 Beta 预览版 22621.1245 和 22623.1245 (KB5022358) 发布