首页    技术博客    PHP教程    数据库技术    前端开发   HTML5    Nginx    php论坛
新用户注册 | 会员登录
8赞
276
当前位置:  开发笔记 > 编程语言 > 正文

IO基本使用方法

作者：龍城灬任少 | 来源：互联网 | 2023-03-19 00:35
管道流用于线程之间的通信。PipedInputStream类与PipedOutputStream类用于在应用程序中创建管道通信.一个PipedInputStream实例对象必须和

管道流用于线程之间的通信。

PipedInputStream类与PipedOutputStream类用于在应用程序中创建管道通信.一个PipedInputStream实例对象必须和一个PipedOutputStream实例对象进行连接而产生一个通信管道.PipedOutputStream可以向管道中写入数据,PipedIntputStream可以读取PipedOutputStream向管道中写入的数据.这两个类主要用来完成线程之间的通信.一个线程的PipedInputStream对象能够从另外一个线程的PipedOutputStream对象中读取数据.

一个线程的PipedInputStream对象从另外一个线程的PipedOutputStream对象读取输入。要使管道流有用&＃xff0c;必须同时构造管道输入流和管道输出流。

一共有两种方式实现管道流&＃xff1a;

方法1 &＃xff1a; 使用Connect进行连接

写入管道&＃xff1a;


[java] view plaincopy
  1. 代码  
  2.   
  3. import java.io.IOException;  
  4. import java.io.PipedOutputStream;  
  5.   
  6. public class Producer extends Thread {  
  7.     private PipedOutputStream pos;  
  8.   
  9.     public Producer(PipedOutputStream pos) {  
  10.         this.pos &＃61; pos;  
  11.     }  
  12.   
  13.     &＃64;Override  
  14.     public void run() {  
  15.         super.run();  
  16.         try {  
  17.             pos.write("Hello".getBytes());  
  18.         } catch (IOException e) {  
  19.             e.printStackTrace();  
  20.         }  
  21.     }  
  22. }  


从管道读出&＃xff1a;


[java] view plaincopy
  1. 代码  
  2.   
  3. import java.io.IOException;  
  4. import java.io.PipedInputStream;  
  5.   
  6. public class Consumer extends Thread {  
  7.     private PipedInputStream pis;  
  8.   
  9.     public Consumer(PipedInputStream pis) {  
  10.         this.pis &＃61; pis;  
  11.     }  
  12.   
  13.     &＃64;Override  
  14.     public void run() {  
  15.         super.run();  
  16.         byte[] b &＃61; new byte[100]; // 将数据保存在byte数组中  
  17.         try {  
  18.             int len &＃61; pis.read(b); // 从数组中得到实际大小。  
  19.             System.out.println(new String(b, 0, len));  
  20.             pis.close();  
  21.         } catch (IOException e) {  
  22.             e.printStackTrace();  
  23.         }  
  24.     }  
  25. }  




Main:


[java] view plaincopy
  1. PipedStreamTest  
  2.   
  3. import java.io.IOException;  
  4. import java.io.PipedInputStream;  
  5. import java.io.PipedOutputStream;  
  6.   
  7. public class PipedStreamTest {  
  8.     public static void main(String[] args) {  
  9.         PipedOutputStream pos &＃61; new PipedOutputStream();  
  10.         PipedInputStream pis &＃61; new PipedInputStream();  
  11.         try {  
  12.             pos.connect(pis);// 连接管道  
  13.   
  14.             new Producer(pos).start();// 启动线程  
  15.   
  16.             new Consumer(pis).start();// 启动线程  
  17.   
  18.         } catch (IOException e) {  
  19.             e.printStackTrace();  
  20.         }  
  21.     }  
  22. }  


从管道读出&＃xff1a;


[java] view plaincopy
  1. 代码  
  2.   
  3. import java.io.IOException;  
  4. import java.io.PipedInputStream;  
  5.   
  6. public class Consumer extends Thread {  
  7.     private PipedInputStream pis;  
  8.   
  9.     public Consumer(PipedInputStream pis) {  
  10.         this.pis &＃61; pis;  
  11.     }  
  12.   
  13.     &＃64;Override  
  14.     public void run() {  
  15.         super.run();  
  16.         byte[] b &＃61; new byte[100]; // 将数据保存在byte数组中  
  17.         try {  
  18.             int len &＃61; pis.read(b); // 从数组中得到实际大小。  
  19.             System.out.println(new String(b, 0, len));  
  20.             pis.close();  
  21.         } catch (IOException e) {  
  22.             e.printStackTrace();  
  23.         }  
  24.     }  
  25. }  




Main:


[java] view plaincopy
  1. PipedStreamTest  
  2.   
  3. import java.io.IOException;  
  4. import java.io.PipedInputStream;  
  5. import java.io.PipedOutputStream;  
  6.   
  7. public class PipedStreamTest {  
  8.     public static void main(String[] args) {  
  9.         PipedOutputStream pos &＃61; new PipedOutputStream();  
  10.         PipedInputStream pis &＃61; new PipedInputStream();  
  11.         try {  
  12.             pos.connect(pis);// 连接管道  
  13.   
  14.             new Producer(pos).start();// 启动线程  
  15.   
  16.             new Consumer(pis).start();// 启动线程  
  17.   
  18.         } catch (IOException e) {  
  19.             e.printStackTrace();  
  20.         }  
  21.     }  
  22. }  




推荐阅读
author-avatar
龍城灬任少
这个家伙很懒，什么也没留下！
Tags | 热门标签
RankList | 热门文章
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有