java - 无阻塞地原子读取 n 个字节

Question

我刚刚问了一个问题，为什么我的线程关闭不起作用。它最终是由于在识别关闭标志之前 readLine() 阻塞了我的线程。通过在调用 readLine() 之前检查 ready() 可以轻松解决此问题。

但是，我现在使用 DataInputStream 连续执行以下操作:

int x = reader.readInt();
int y = reader.readInt();
byte[] z = new byte[y]
reader.readFully(z);

我知道我可以实现自己的缓冲，它会在加载缓冲区时检查正在运行的文件标志。但我知道这会很乏味。相反，我可以让数据在 InputStream 类中缓冲，并等到我读取了 n 字节，然后再执行非阻塞读取 - 正如我所知我需要阅读很多内容。

• 第一个整数为 4 字节
• 4 字节表示第二个整数 y
• 和 y 字节表示 z 字节数组。

不是使用 ready() 来检查缓冲区中是否有一行，而是有一些等效的 ready(int bytesNeeded) 吗？

Answer 1

available() 方法返回 InputStream 内部缓冲区中的字节数。

所以，人们可以做这样的事情:

while (reader.available() < 4) checkIfShutdown();
reader.readInt();