通过管道流进行线程间的通信

淩亂°似流年 2022-05-13 11:06 146阅读 0赞

一.概述

1）.在Java语言中提供了各种各样的输入/输出流Stream,使我们能够方便地对数据进行操作，其中管道流(pipeStream)是一种特殊的流，用于在不同线程间直接传递数据。一个线程发送数据到输出管道，另一个线程从输出管道中读取数据。通过使用管道，实现不同线程间的通信，而无须借助类似临时文件之类的东西。

2）.在Java的JDK中提供了4个类来使线程间可以进行通信：

a.PipedInputStream和PipedOutputStream（字节流）

b.PipedReader和PipedWriter（字符流）

二.代码（字节流案例）

package org.zhq.pipeStream;
    
    import java.io.PipedOutputStream;
    
    /**
     * @author 作者 hq.zheng:
     * @version 创建时间：2018-9-12 下午2:21:35
     * 类说明: 写入数据到内存
     */
    public class WriteData {
    	public void writeMethod(PipedOutputStream out){
    		try {
    			System.out.println("write:");
    			for(int i=0;i<300;i++){
    				String outData=""+(i+1);
    				out.write(outData.getBytes());
    				System.out.print(outData);
    			}
    			System.out.println();
    			out.close();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    }

package org.zhq.pipeStream;
    
    import java.io.PipedInputStream;
    
    /**
     * @author 作者 hq.zheng:
     * @version 创建时间：2018-9-12 下午2:26:27
     * 类说明: 从内存里读数据
     */
    public class ReadData {
    	public void ReadMethod(PipedInputStream input){
    		try {
    			System.out.println("read :");
    			byte[] byteArray=new byte[20];
    			int readLength=input.read(byteArray);
    			while(readLength!=-1){
    				String newData=new String(byteArray,0,readLength);
    				System.out.print(newData);
    				readLength=input.read(byteArray);
    			}
    			System.out.println();
    			input.close();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    }

package org.zhq.pipeStream;
    
    import java.io.PipedOutputStream;
    
    /**
     * @author 作者 hq.zheng:
     * @version 创建时间：2018-9-12 下午2:34:33
     * 类说明： 写数据线程
     */
    public class ThreadWrite extends Thread {
    	private WriteData write;
    	private PipedOutputStream out;
    	public ThreadWrite(WriteData write,PipedOutputStream out){
    		super();
    		this.write=write;
    		this.out=out;
    	}
    	@Override
    	public void run(){
    		write.writeMethod(out);
    	}
    }

package org.zhq.pipeStream;
    
    import java.io.PipedInputStream;
    
    /**
     * @author 作者 hq.zheng:
     * @version 创建时间：2018-9-12 下午2:38:10
     * 类说明： 读数据线程
     */
    public class ThreadRead extends Thread {
    	private ReadData read;
    	private PipedInputStream input;
    	public ThreadRead(ReadData read,PipedInputStream input){
    		super();
    		this.read=read;
    		this.input=input;
    	}
    	@Override
    	public void run(){
    		read.ReadMethod(input);
    	}
    }

package org.zhq.pipeStream;
    
    import java.io.PipedInputStream;
    import java.io.PipedOutputStream;
    
    /**
     * @author 作者 hq.zheng:
     * @version 创建时间：2018-9-12 下午2:45:37
     * 类说明 ：测试运行
     */
    public class Run {
    
    	public static void main(String[] args) {
    		try {
    			WriteData writeData=new WriteData();
    			ReadData readData=new ReadData();
    			
    			PipedInputStream inputStream=new PipedInputStream();
    			PipedOutputStream outputStream=new PipedOutputStream();
    			
    			outputStream.connect(inputStream);
    			
    			ThreadRead threadRead=new ThreadRead(readData, inputStream);
    			threadRead.start();
    			
    			Thread.sleep(2000);
    			
    			ThreadWrite threadWrite=new ThreadWrite(writeData, outputStream);
    			threadWrite.start();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    
    	}
    
    }

三.结果

![70][]

首先是读取读取线程先启动，由于没有数据，所以阻塞在in.read(byteArray),直到有数据被写入，才继续向下运行。

[70]: /images/20220513/f4ac611d9e4f48d8a9a81af1510b4e11.png