为什么 FileInputStream read() 不阻塞？

Question

我有一个 Writer 程序，它将一行文本写入文件，然后等到用户按回车键后再写入另一行，然后退出。只有在那之后文件才会关闭。代码：

public class Writer {

    Writer() {
    }

    public static String[] strings = 
        {
            "Hello World", 
            "Goodbye World"
        };

    public static void main(String[] args) 
        throws java.io.IOException {

        java.io.FileOutputStream pw =
            new java.io.FileOutputStream("myfile.txt");

        for(String s : strings) {
            pw.write(s.getBytes());
            System.in.read();
        }

        pw.close();
    }
}

首先开始：

java 编写器

然后我还有一个阅读器程序，只要文件的写入尚未完成（即 pw.close() 尚未被调用），它就应该（我期望）阻塞。代码：

public class ReaderFIS extends Object {

    ReaderFIS() {
    }

    public static void main(String[] args) throws Exception {

        java.io.FileInputStream in = new java.io.FileInputStream("myfile.txt");

        int ch = -1;
        while((ch = in.read()) >= 0) {
         System.out.println("ch = " + ch);
     }
        System.out.println("Last ch = " + ch);

     System.out.println("exiting");
    }
}

开头：

java ReaderFIS

现在，根据 Javadoc 文档中的内容，我预计 read() 在读取第一个“Hello World”文本后会阻塞：

从此输入流读取一个字节的数据。如果尚无可用输入，则此方法会阻塞。 通过： http://docs. oracle.com/javase/6/docs/api/java/io/FileInputStream.html#read()

但是 ReaderFIS 在读取“Hello World”后立即完成，并且显然看到了 EOF！所以它不阻止！它转储字符值，然后转储 -1，然后打印“exiting”。

输出： 通道 = 72 通道 = 101 通道 = 108 通道 = 108 通道 = 111 通道 = 32 频道 = 87 通道 = 111 通道 = 114 通道 = 108 通道 = 100 最后一个频道 = -1 我尝试过的

其他变体是：通过 getChannel() 读取、通过 getChannel() 检查是否可以锁定()、使用 available()、尝试使用缓冲区的 read()、尝试 readLine()、连续写入字符在文件中，每次写入之间有 500 毫秒的暂停，不写入任何内容，只是保持文件在写入器中打开。
这些变化都不会导致 ReaderFIS 程序阻塞，它总是会完成。

为什么阅读器程序不阻塞？我错过了一些非常明显的事情吗？ ReaderFIS 程序似乎找到了 EOF (-1)，但为什么呢？ Writer 程序尚未关闭该文件。

“有趣”的旁注：System.in.read() 被阻塞了！ （并等待用户按 Enter 键）。

PS：在 Windows XP 和 Suse Linux 上尝试过。在 Windows 上，当编写器运行时我无法删除该文件（正如我所期望的那样）。

问候， 马可

Answer 1

FileInputStream 总是有可用的输入：要么还有字节需要读取，要么有 EOF，但一般情况下读取时不会阻塞。当您执行以下操作时，您可能会被阻止：

• 从控制台/终端读取
• 从网络
• 读取 从管道
• 读取 等待数据的任何流。

文件流不必等待数据，因为它们始终有可用数据：在您的情况下，read() 基本上会随机获得以下之一：

• 文件的旧版本
• 、文件的新版本文件的
• 文件的半更新版本。

Answer 2

您的阅读器程序将读取文件中的所有内容，然后到达末尾并返回 -1。如果您运行时它包含的全部内容是“Hello World”，那么这就是它能够读取的全部内容。如果在编写器中按回车键后再次运行它，您应该看到“Hello World Goodbye World”。

没有更多可用字节和到达流末尾是两件不同的事情。这就是 System.in.read() 阻塞而 FileInputStream.read() 不阻塞的原因。

Answer 3

您不能将文件用作管道。

但是，您可以使用管道作为管道。

Answer 4

你稍微没明白是什么阻碍了。阻塞IO是指阻塞程序的执行，直到IO操作完成。 close 只是断开程序与文件的连接。如果您希望一个应用程序阻止另一个应用程序，您应该使用某种同步。

Answer 5

您可能需要一些东西来延迟数据的实际读取。检查此源代码： http://www.java2s.com/Open-Source/Java/Web-Server/Jigsaw/org/w3c/jigsaw/ssi/DelayedInputStream.java.htm。