管道流的简单例子

Love The Way You Lie 2022-06-12 08:59 134阅读 0赞

public class PipedStreamDemo  {
    	public static void main(String[] args) throws IOException {
    		PipedOutputStream out = new PipedOutputStream();
    		PipedInputStream in = new PipedInputStream(out);
    		Input input = new Input(in);
    		Output output = new Output(out);
    		input.start();
    		output.start();
    	}
    	static class Input extends Thread{
    		PipedInputStream in;
    		public Input(PipedInputStream in){
    			this.in = in;
    		}
    		public void run() {
    			byte[] bytes = new byte[1024];
    			try {
    				while(true){
    					//因为read方法是阻塞式的，没数据就等待，有数据立刻就读
    					int i = in.read(bytes);
    					String str = new String(bytes,0,i);
    					System.out.println("接收线程##"+str);
    				}
    			} catch (Exception e) {
    				e.printStackTrace();
    			}
    		}
    		
    	}
    	static class Output extends Thread{
    		PipedOutputStream out;
    		public Output(PipedOutputStream out){
    			this.out = out;
    		}
    		public void run() {
    			try {
    				while(true){
    					InputStream is = System.in;
    					byte[] bytes = new byte[1024];
    					int len = is.read(bytes);
    					out.write(new String(bytes,0,len).getBytes());
    					out.flush();
    				}
    			} catch (IOException e) {
    				e.printStackTrace();
    			}
    		}
    		
    	}
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，134人围观）

还没有评论，来说两句吧...

相关阅读

相关管道流：字节管道流、字符管道流

在Java中，有字节管道流（Byte Pipe Streams）和字符管道流（Character Pipe Streams），它们是用于线程之间数据通信的一种方式。字节管道流主

╰+哭是因爲堅強的太久メ/ 2023年10月16日 13:37/ 0 赞/ 7 阅读

相关 Linnux无名管道的创建例子

例子：创建一个进程两个管道从一管道写入小写字符串，另一管道读出大写字符串 include <stdio.h> include<unistd.h>

灰太狼/ 2022年10月01日 02:49/ 0 赞/ 144 阅读

相关打印流PrintStream、管道流

Java程序设计精讲第12章—— java流与文件操作打印流PrintStream PrintStream：是一个字节打印流，System.out对应的类型就是P

快来打我*/ 2022年06月18日 01:49/ 0 赞/ 194 阅读

相关 NIO管道流的操作

在多线程的环境下,线程之间可以通过管道来实现数据交互,而这个管道在NIO中通过Pipe类进行实现,ipe有一个source通道和一个sink通道。数据会被写到sink通道,从s

怼烎@/ 2022年06月14日 04:54/ 0 赞/ 219 阅读

相关管道流的简单例子

public class PipedStreamDemo { public static void main(String[] args) throws I

Love The Way You Lie/ 2022年06月12日 08:59/ 0 赞/ 135 阅读

相关 javaIO——管道流

本节目标：了解管道流的操作管道流管道流的主要作用是可以进行两个线程间的通讯，分为管道输出流（PipedOutputStream）和管道输入流（PipedInpu

末蓝、/ 2022年05月28日 10:50/ 0 赞/ 348 阅读

相关流、管道、重定向

重定向：显示的命令结果输送到其他地方。管道：两个命令连起来。一个输出一个输入。命令的结果可以“流向”：终端，文件，其他命令。 >和>>：重定向到文件

短命女/ 2022年05月26日 00:17/ 0 赞/ 237 阅读

相关管道流练习

/ 程序头部注释开始程序的版权和版本声明部分 Copyright (c) 2011, 烟台大学计算机学院学生

短命女/ 2022年05月16日 04:56/ 0 赞/ 180 阅读

相关文件流管道（pipe）

在Node.js中读取文件时为使用非阻塞IO，我们可以这样写： fs.createReadStream('./lvgu.jpg').on('data', (data

港控/mmm°/ 2022年05月11日 14:42/ 0 赞/ 219 阅读

相关 Java--管道输入/输出流

管道输入/输出流管道输入/输出流和普通的文件输入/输出流或者网络输入/输出流不同之处在于，它主要用于线程之间的数据传输，而传输的媒介为内存。管道输入/输出流主要包括

悠悠/ 2021年08月13日 18:17/ 0 赞/ 373 阅读