java 管道流代码示例

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

public class PipedStream {

/**
* @param args
* @throws IOException
*/
public static void main(String[] args) throws IOException {

PipedInputStream input = new PipedInputStream();
  PipedOutputStream output = new PipedOutputStream();

  input.connect(output);

  new Thread(new Input(input)).start();
  new Thread(new Output(output)).start();

}

}

class Input implements Runnable{

private PipedInputStream in;
Input(PipedInputStream in){
  this.in = in;
}
public void run(){

  try {
   byte[] buf = new byte[1024];
   int len = in.read(buf);

   String s = new String(buf,0,len);

   System.out.println("s="+s);
   in.close();
  } catch (Exception e) {
   // TODO: handle exception
  }

}
}

class Output implements Runnable{
private PipedOutputStream out;
Output(PipedOutputStream out){
  this.out = out;
}
public void run(){

  try {
   Thread.sleep(5000);
   out.write("hi，管道来了！".getBytes());
  } catch (Exception e) {
   // TODO: handle exception
  }
}
}

巴特西

java 管道流代码示例

最新文章

热门文章