Java IO操作——线程间通讯流（管道流 PipedOutputStream、PipedInputStream）

缺乏、安全感 2022-09-23 15:51 171阅读 0赞

管道流

管道流的作用是可以进行两个线程间的通讯，分为管道输出流(PipedOutputStream)、管道输入流(PipedInputStream)如果要想进行管道输出，则必须把输出流连在输入流之上，在PipedOutputStream中有一个方法用于连接管道：

**public void connect(PipedInputStream snk) throws IOException**

![Center][]

要想实现管道流，则可以使用PipedOutputStream和PipedInputStream

public void connect(PipedInputStream snk) throws IOException

如果要连接此输出，就必须使用此方法。

import java.io.* ;
    class Send implements Runnable{			// 线程类
    	private PipedOutputStream pos = null ;	// 管道输出流
    	public Send(){
    		this.pos = new PipedOutputStream() ;	// 实例化输出流
    	}
    	public void run(){
    		String str = "Hello World!!!" ;	// 要输出的内容
    		try{
    			this.pos.write(str.getBytes()) ;
    		}catch(IOException e){
    			e.printStackTrace() ;
    		}
    		try{
    			this.pos.close() ;
    		}catch(IOException e){
    			e.printStackTrace() ;
    		}
    	}
    	public PipedOutputStream getPos(){	// 得到此线程的管道输出流
    		return this.pos ;	
    	}
    };
    class Receive implements Runnable{
    	private PipedInputStream pis = null ;	// 管道输入流
    	public Receive(){
    		this.pis = new PipedInputStream() ;	// 实例化输入流
    	}
    	public void run(){
    		byte b[] = new byte[1024] ;	// 接收内容
    		int len = 0 ;
    		try{
    			len = this.pis.read(b) ;	// 读取内容
    		}catch(IOException e){
    			e.printStackTrace() ;
    		}
    		try{
    			this.pis.close() ;	// 关闭
    		}catch(IOException e){
    			e.printStackTrace() ;
    		}
    		System.out.println("接收的内容为：" + new String(b,0,len)) ;
    	}
    	public PipedInputStream getPis(){
    		return this.pis ;
    	}
    };
    public class PipedDemo{
    	public static void main(String args[]){
    		Send s = new Send() ;
    		Receive r = new Receive() ;
    		try{
    			s.getPos().connect(r.getPis()) ;	// 连接管道
    		}catch(IOException e){
    			e.printStackTrace() ;
    		}
    		new Thread(s).start() ;	// 启动线程
    		new Thread(r).start() ;	// 启动线程
    	}
    };

![Center 1][]

实际上在JAVA开发中很少直接去开发多线程程序，我只是为了系统的裂解一下IO操作有关的内容。

[Center]: /images/20220720/a2c45c33d4a54dd1961f0be8b9055c3a.png
[Center 1]: /images/20220720/6055ce031d924eb19dcfef1ee6738430.png