这篇文章主要介绍Java管道流实现线程间通信过程的示例分析，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！
创新互联建站是一家朝气蓬勃的网站建设公司。公司专注于为企业提供信息化建设解决方案。从事网站开发，网站制作，网站设计，网站模板，微信公众号开发，软件开发，小程序设计，十余年建站对成都木制凉亭等多个行业，拥有多年建站经验。
管道流
在Java语言中提供了各种各样的输入/输出流 Stream ，使我们能够很方便地对数据进行操作，其中管道流是一种特殊的流，用于在不同线程间直接传送数据。一个线程发送数据到输出管道流，另一个线程从输入管道流中读取数据。
通过使用管道，实现不同线程间的通信，而无须借助于类似临时文件之类的东西。
字节流
PipedInputStream 和 PipedOutputStream
字符流
PipedReader 和 PipedWriter
示例
public class PipeStreamTest {
public static void main(String[] args) throws IOException, InterruptedException {
WriteData writeData = new WriteData();
ReadData readData = new ReadData();
PipedReader reader = new PipedReader();
PipedWriter writer = new PipedWriter();
writer.connect(reader);
new Thread(() -> {
writeData.writeMethod(writer);
}).start();
Thread.sleep(2000);
new Thread(() -> {
readData.readMethod(reader);
}).start();
}
static class WriteData {
public void writeMethod(PipedWriter writer) {
try {
System.out.println("write :");
for (int i = 0; i < 300; i++) {
String outData = "" + (i + 1);
writer.write(outData);
System.out.print(outData);
}
System.out.println();
writer.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
static class ReadData {
public void readMethod(PipedReader reader) {
try {
System.out.println("read :");
char[] byteArray = new char[20];
int readLength = reader.read(byteArray);
while (readLength != -1) {
String newData = new String(byteArray, 0, readLength);
System.out.print(newData);
readLength = reader.read(byteArray);
}
System.out.println();
reader.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}运行结果如下：
1. 简单，只需理解基本的概念，就可以编写适合于各种情况的应用程序；2. 面向对象；3. 分布性，Java是面向网络的语言；4. 鲁棒性，java提供自动垃圾收集来进行内存管理，防止程序员在管理内存时容易产生的错误。；5. 安全性，用于网络、分布环境下的Java必须防止病毒的入侵。6. 体系结构中立，只要安装了Java运行时系统，就可在任意处理器上运行。7. 可移植性，Java可以方便地移植到网络上的不同机器。8.解释执行，Java解释器直接对Java字节码进行解释执行。
以上是“Java管道流实现线程间通信过程的示例分析”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注创新互联行业资讯频道！
