黑马程序员技术交流社区

标题: 有关管道流的一个问题？ [打印本页]
作者: 肖勇    时间: 2013-9-25 00:32
标题: 有关管道流的一个问题？
什么时候要用管道流啊！他有什么好处？看老毕的视频时，有点不清楚！请各位大神解释下。。。
作者: 陈洋    时间: 2013-9-25 00:50

管道流可以实现两个线程之间，二进制数据的传输。

管道流就像一条管道，一端输入数据，别一端则输出数据。通常要分别用两个不同的线程来控制它们。

使用方法如下：
  1. import java.io.IOException;
  2. import java.io.PipedInputStream;
  3. import java.io.PipedOutputStream;

  5. public class PipedInputStreamTest {

  7.         public static void main(String[] args) {
  8.                 //管道输出流
  9.                 PipedOutputStream out = new PipedOutputStream();
  10.                 //管道输入流
  11.                 PipedInputStream in = null;
  12.                 try {
  13.                         //连接两个管道流。或者调用connect(Piped..);方法也可以
  14.                         in = new PipedInputStream(out);
  15.                         Thread read = new Thread(new Read(in));
  16.                         Thread write = new Thread(new Write(out));
  17.                         //启动线程
  18.                         read.start();
  19.                         write.start();
  20.                 } catch (IOException e) {
  21.                         e.printStackTrace();
  22.                 }
  23.         }
  24. }

  26. class Write implements Runnable {
  27.         PipedOutputStream pos = null;

  29.         public Write(PipedOutputStream pos) {
  30.                 this.pos = pos;
  31.         }

  33.         public void run() {
  34.                 try {
  35.                         System.out.println("程序将在3秒后写入数据，请稍等。。。");
  36.                         Thread.sleep(3000);
  37.                         pos.write("wangzhihong".getBytes());
  38.                         pos.flush();
  39.                 } catch (IOException e) {
  40.                         e.printStackTrace();
  41.                 } catch (InterruptedException e) {
  42.                         e.printStackTrace();
  43.                 } finally {
  44.                         try {
  45.                                 if (pos != null) {
  46.                                         pos.close();
  47.                                 }
  48.                         } catch (IOException e) {
  49.                                 e.printStackTrace();
  50.                         }
  51.                 }
  52.         }
  53. }

  55. class Read implements Runnable {
  56.         PipedInputStream pis = null;

  58.         public Read(PipedInputStream pis) {
  59.                 this.pis = pis;
  60.         }

  62.         public void run() {
  63.                 byte[] buf = new byte[1024];
  64.                 try {
  65.                         pis.read(buf);
  66.                         System.out.println(new String(buf));
  67.                 } catch (IOException e) {
  68.                         e.printStackTrace();
  69.                 } finally {
  70.                         try {
  71.                                 if (pis != null) {
  72.                                         pis.close();
  73.                                 }
  74.                         } catch (IOException e) {
  75.                                 e.printStackTrace();
  76.                         }
  77.                 }
  78.         }
  79. }
复制代码




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