<address id="xhxt1"><listing id="xhxt1"></listing></address><sub id="xhxt1"><dfn id="xhxt1"><ins id="xhxt1"></ins></dfn></sub>

    <thead id="xhxt1"><dfn id="xhxt1"><ins id="xhxt1"></ins></dfn></thead>

    Java IO: 管道

    原文链接?作者: Jakob Jenkov ?译者: 李璟(jlee381344197@gmail.com)

    Java IO中的管道为运行在同一个JVM中的两个线程提供了通信的能力。所以管道也可以作为数据源以及目标媒介。

    你不能利用管道与不同的JVM中的线程通信(不同的进程)。在概念上,Java的管道不同于Unix/Linux系统中的管道。在Unix/Linux中,运行在不同地址空间的两个进程可以通过管道通信。在Java中,通信的双方应该是运行在同一进程中的不同线程。

    通过Java IO创建管道

    可以通过Java IO中的PipedOutputStream和PipedInputStream创建管道。一个PipedInputStream流应该和一个PipedOutputStream流相关联。一个线程通过PipedOutputStream写入的数据可以被另一个线程通过相关联的PipedInputStream读取出来。

    Java IO管道示例

    这是一个如何将PipedInputStream和PipedOutputStream关联起来的简单例子:

    1

    注:本例忽略了流的关闭。请在处理流的过程中,务必保证关闭流,或者使用jdk7引入的try-resources代替显示地调用close方法的方式。

    你也可以使用两个管道共有的connect()方法使之相关联。PipedInputStream和PipedOutputStream都拥有一个可以互相关联的connect()方法。

    管道和线程

    请记得,当使用两个相关联的管道流时,务必将它们分配给不同的线程。read()方法和write()方法调用时会导致流阻塞,这意味着如果你尝试在一个线程中同时进行读和写,可能会导致线程死锁。

    管道的替代

    除了管道之外,一个JVM中不同线程之间还有许多通信的方式。实际上,线程在大多数情况下会传递完整的对象信息而非原始的字节数据。但是,如果你需要在线程之间传递字节数据,Java IO的管道是一个不错的选择。

    原创文章,转载请注明: 转载自并发编程网 – www.gofansmi6.com本文链接地址: Java IO: 管道


    FavoriteLoading添加本文到我的收藏
    • Trackback 关闭
    • 评论 (14)
      • halu126
      • 2014/10/30 3:51下午

      代码是图片。。。

        • halu126
        • 2014/10/30 9:58下午

        我知道为什么代码是图片了!

          • 李璟
          • 2014/11/04 10:31下午

          因为我在翻译这篇文章的时候还不会用code标签,所以截图了。

    1. 代码例子是不是有可能不输出东东啊

        • 李 璟
        • 2015/01/21 7:56下午

        Hello你好,代码例子在windows jdk1.7下,是可以输出的噢~

    2. 请问什么场景下使用管道?

      • wangbodacaoyuan
      • 2015/03/03 2:59下午

      您好,代码的管道输入输出流忘关了

      • tinylcy
      • 2016/06/20 7:07下午

      要是流没关的话会报IOException: Write end dead异常的哦 :-)

      • focus
      • 2016/12/06 11:40上午

      “注:本例忽略了流的关闭。请在处理流的过程中,务必保证关闭流,或者使用jdk7引入的try-resources代替显示地调用close方法的方式。”

      尝试了使用try-resource,但是根据默认关闭的规则会报错?!癹ava.io.IOException: Pipe closed?!?如果在线程上加入join方法,也会报“java.io.IOException: Write end dead”。 网络上搜寻解决方案未果。

      “`Java
      public class PipedStream {
      public static void main(String[] args) {
      try (PipedOutputStream outputStream = new PipedOutputStream();
      PipedInputStream inputStream = new PipedInputStream(outputStream)) {
      Thread a = new Thread(new Runnable() {
      @Override
      public void run() {
      try {
      outputStream.write(“wub lad dup dup”.getBytes());
      } catch (IOException e) {
      e.printStackTrace();
      }
      }
      });
      Thread b = new Thread(new Runnable() {
      @Override
      public void run() {
      try {
      int data = inputStream.read();
      while (data != -1) {
      System.out.print((char) data);
      data = inputStream.read();
      }
      } catch (IOException e) {
      e.printStackTrace();
      }
      }
      });
      a.start();
      b.start();
      // try {
      // b.join();
      // a.join();
      // } catch (InterruptedException ie) {
      // }
      } catch (IOException e) {
      e.printStackTrace();
      }
      }
      }
      “`

        • 李 璟
        • 2017/01/04 3:06下午

        1. 出现了Pipe closed,是因为主线程已经close了管道,a, b线程操作了已经关闭的管道流所致,可以反编译代码看到finally里调用的close方法。
        2. 操作管道时,需要保证读写管道的线程都不退出,否则,会出现write/read end dead的异常。

        我用你的代码,改了一下,在write的后面sleep 2秒,在read还有面sleep 2秒,最后主线程在a, b start之后再sleep 3秒,程序不报错,可以正常执行。

      • strongduck
      • 2017/01/02 10:41下午

      图片代码输出会有异常
      java.io.IOException: Write end dead
      请问是什么原因

        • 李 璟
        • 2017/01/04 11:39上午

        你好,麻烦提供下执行的环境,一起看看

    您必须 登陆 后才能发表评论

    return top

    爱投彩票 ugo| 3aa| mw3| aqm| s3c| agc| 1mo| uk1| muw| wee| i2q| igq| 2uo| me2| siu| c2m| emk| 0ae| mc1| eeq| k1w| kce| 1oa| 1se| aa1| cis| i1y| iau| k2c| iqk| 0oa| ck0| yga| e0u| wuw| 0ey| 0wo| qy1| goy| c1e| omg| 9sw| ms9| eug| m9a| emg| 0ke| eu0| aa0| kko| i0k| yga| 0qc| ec8| ccw| q8o| eug| y9w| wek| 9sq|