Java知識點總結(jié)（JavaIO-管道流）

BenCHou 發(fā)布于2019-08-15 15:36 / 1968人閱讀

摘要：知識點總結(jié)管道流知識點總結(jié)管道流的主要作用是可以進行兩個線程間的通信。如果要進行管道輸出，則必須把輸出流連接在輸入流上，在類上有如下方法用于連接管道。

Java知識點總結(jié)（JavaIO-管道流）

@(Java知識點總結(jié))[Java, JavaIO]

[toc]

管道流的主要作用是可以進行兩個線程間的通信。

  如果要進行管道輸出，則必須把輸出流連接在輸入流上，在PipeOutputStream類上有如下方法用于連接管道。

public class Demo07 {
  
  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();
  }
 
}
 
 
class  Send implements Runnable{
  private PipedOutputStream pos = null;
  
  public Send (){
    this.pos = new PipedOutputStream();
  }
 
  @Override
  public void run() {
    String s = "hello world";
    try {
      pos.write(s.getBytes());
    } catch (IOException e) {
      e.printStackTrace();
    }
    try {
      pos.close();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
 
  public PipedOutputStream getPos() {
    return pos ;
  }
  
}
  
 
class  Receive implements Runnable{
    private PipedInputStream pis;
  
    public Receive() {
      this.pis = new PipedInputStream();
    }
 
    @Override
    public void run() {
      byte[] b = new byte[1024];
      int len = 0;
      try {
        len = this.pis.read(b);
      } catch (IOException e) {
        e.printStackTrace();
      }
      
      try {
        pis.close();
      } catch (IOException e) {
        e.printStackTrace();
      }
      
      System.out.println("接收的內(nèi)容為:" + new String (b,0,len));
    }
 
    public PipedInputStream getPis() {
      return pis;
    }
 
}