黑马程序员技术交流社区

标题: 管道流的连接的小问题 [打印本页]
作者: 王浩龙    时间: 2014-3-18 11:45
标题: 管道流的连接的小问题
  1. import java.io.IOException;
  2. import java.io.PipedInputStream;
  3. import java.io.PipedOutputStream;

  5. class Read implements Runnable{
  6.         private PipedInputStream in;
  7.         Read(PipedInputStream in){
  8.                 this.in = in;
  9.         }
  10.         @Override
  11.         public void run() {
  12.                 byte[] b = new byte[1024];
  13.                 int len = 0;
  14.                 try {
  15.                         System.out.println("xiuxiyixia 6miao");
  16.                         Thread.sleep(6000);
  17.                         len = in.read(b);
  18.                         System.out.println(new String(b, 0, len));
  19.                 } catch (Exception e) {
  20.                         throw new RuntimeException("管道流读取失败");
  21.                 }
  22.                 finally{
  23.                                 if(in!=null)
  24.                                 try {
  25.                                         in.close();
  26.                                 } catch (IOException e) {
  27.                                         e.printStackTrace();
  28.                                 }
  29.                 }       
  30.         }
  31.        
  32. }
  33. class Write implements Runnable{
  34.         private PipedOutputStream out;
  35.         Write(PipedOutputStream out){
  36.                 this.out = out;
  37.         }
  38.         @Override
  39.         public void run() {
  40.                 try {
  41.                  out.write("asdasdasfwq".getBytes());;
  42.                 } catch (IOException e) {
  43.                         throw new RuntimeException("管道流写入取失败");
  44.                 }
  45.                 finally{
  46.                                 if(out!=null)
  47.                                 try {
  48.                                         out.close();
  49.                                 } catch (IOException e) {
  50.                                         e.printStackTrace();
  51.                                 }
  52.                 }
  53.                
  54.         }
  55.        
  56. }
  57. public class PipedStreamTest {

  59.         public static void main(String[] args) throws IOException {
  60.                 PipedInputStream in = new PipedInputStream();
  61.                 PipedOutputStream out = new PipedOutputStream();
  62.                 in.connect(out);//这里的我们可以用out去连接in吗？
  63.                 Read r = new Read(in);
  64.                 Write w = new Write(out);
  65.                 new Thread(r).start();
  66.                 new Thread(w).start();       
  67.         }
  68. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2