想问一个关于 IO 流的细节

[pocketz]

问题

如果对一个 InputStream 调用 read 方法，在没有数据可读取的时候，理论上会处于阻塞状态。

This method blocks until input data is available, end of file is detected, or an exception is thrown.

那么如果一个 IO 流，曾经有数据可读取但已经被读取完毕，但后续仍有可能增加可读取的数据，此时调用 read ，是不是仍然属于这里所说的“blocks until input data is available”，也就是，是否会发生阻塞？

例子

我获取了 Process 的 InputStream ，里面的内容是这个进程的标准输出（以及错误输出）。
显然，进程的输出是间断性的，我想知道现有输出已经被读完的情况下，此时再调用 read ，是否还会处于阻塞状态?

    private ProcessBuilder dumpProcessBuilder;
    ByteArrayOutputStream outputBuffer = new ByteArrayOutputStream(1024);
    ...
    dumpProcessBuilder.redirectErrorStream(true);
    ...
    Process dumpProcess = dumpProcessBuilder.start();
    try (InputStream in = procForReader.getInputStream()) {
        byte[] buf = new byte[1024];
        int bytesRead = 0;
        while ((bytesRead = in.read(buf)) != -1) {
            output.write(buf, 0, outputBuffer);
        }
    }
    ...

[seedhk]

是的，仍然会

[AoEiuV020JP]

这种比起自己硬想， 不如让 AI 直接写一个能测试这点的代码出来，实际跑一下看看更理解，

[cnhongwei]

进程结束，流就会关闭，你读的时候就返回-1,不可能一直阻塞啊。如果没有关闭，就会阻塞。

[dode]

会堵塞到进程退出吧，你测试看看

[BingoXuan]

是的，系统就是这么设计的。除非你设置成异步 IO ，通过多路复用规避

[sockpuppet9527]

caller 始终阻塞，直到 producer 端产生新的数据或 producer 端显示调用 Close 。

[Sezxy]

只要没读到 EOF 就会一直阻塞

[mmdsun]

@BingoXuan Process 的 getInputStream()也能异步 I/O 吗？ 我记得 Java 标准库里好像不支持的。

[gongxuanzhang]

@Sezxy 正解

[BingoXuan]

@mmdsun
我只是从系统本身设计出发。理论上底层实现就是堵塞的，应该选择第三方库用 c/c++桥接 epoll/iocp 处理。这也是为什么不喜欢 java 的原因，工作上太多需要面向 OS 编程，Java 并不是一个好选择

[pocketz]

@mmdsun getInputStream() 肯定不能异步吧，异步的都在 nio 包里
对于我的需求，Copliot 的做法是新建了一个线程来专门读写进程的输出，也算是变相的异步读取了 XD

[mmdsun]

@pocketz 意思是 Java 没有办法实现 epoll 那样支持 pipe/socket 。只有网络 socket 才支持多路复用和异步。

差一个 process.getOutputChannel()的 API 。

不过我怀疑，pipe 没有网卡硬件、DMA 或中断事件源，即使是 c 语言估计也实现不了“真正的多路复用+异步”。具体的就要问下 5 楼的 BingoXuan 了。