【java基础：IO】管道流PipedInputStream和PipedOutputStream的Demostration

Bertha 。 2022-06-06 14:14 117阅读 0赞

package pipedinputouput;
    
    import java.io.IOException;
    import java.io.PipedInputStream;
    import java.io.PipedOutputStream;
    
    public class PipedInputOutputStreamDemo {
    	
    	/*
    	 * 需求：分别为管道流的读和写开辟线程！
    	 */
    	public static void main(String[] args) throws IOException {
    		PipedInputStream pis=new PipedInputStream();
    		PipedOutputStream pos=new PipedOutputStream();
    		pis.connect(pos);
    		new Thread(new Input(pis)).start();
    		new Thread(new Output(pos)).start();
    	}	
    }
    class Input implements Runnable{
    	private PipedInputStream pis;
    	public Input(PipedInputStream pis) {
    		super();
    		this.pis = pis;
    	}
    	@Override
    	public void run() {
    		try {
    			byte[] buf=new byte[1024];
    			int len=pis.read(buf);
    			String str=new String(buf,0,len);	
    			System.out.println(str);
    		}
    		catch(Exception e){	
    		}
    		finally {
    			try {
    				pis.close();
    			}catch (IOException e) {			
    				e.printStackTrace();
    			}
    		}
    	}
    }
    class Output implements Runnable{
    	private PipedOutputStream pos;
    	public Output(PipedOutputStream pos) {
    		super();
    		this.pos = pos;
    	}
    	@Override
    	public void run() {
    		try {
    			Thread.sleep(3000);
    			pos.write("这是管道流的信息，O(∩_∩)O~".getBytes());
    		} catch(Exception e) {
    			//
    		}
    	}
    }