node.js - 可读的高水位有用性

Question

如果我们不在 _read() 方法中处理它，那么在实现可读流时，highWaterMark 是否有实用程序？

如果我理解正确，则程序员可以自行决定停止读取，如果他不这样做，则没有任何东西可以限制它(甚至管道)。

Answer 1

TL;DR:是的，但是这不是您需要担心的事情。 :)

你是对的，highWaterMark 对实际读取(或生成数据)没有任何影响，但它确实对 Readable.._read 有直接影响，或者更确切地说，它影响您从 Readable..push 获取的信息。因此，尽管您不需要也不应该在您的 _read 实现中包含任何基于它的逻辑 - 它确实有一个实用程序。

为了解释这一点，让我们从 Readable.._read 上的文档开始。 - 当流数据低于 _highWaterMark 时，理想情况下会在到达需要发出 drain 事件的点之前调用 _read。每当调用该方法时，它都会在实现调用 push 方法之前阻止进一步的调用。

所以你所说的，没有什么可以阻止你编写这个实现:

_read(sizeRequired) {
    const x = readLotsOfChunksDisregardingSizeRequired();
    x.forEach(chunk => this.push(chunk);
}

当然，这是事实，在某些情况下，如果您无法真正控制读取，那么这是可以接受的。不过，_highWaterMark 还用于在 push 方法中为您提供快速反馈信息。

因此，如果我们考虑另一种可以控制源的实现:

_read(numRequired) {
    while (true) { // I know, I know don't write while true's...
        const chunk = readASingleChunk();
        if (!this.push(chunk))
            return;
    }
}

在这种情况下，将在写入每个 block 后检查_highWaterMark机制，如果您确实达到highWaterMark，this.push(chunk)将返回false，并且您的流将根据需要使用尽可能少的内存，并且还将继续以合理的速率流动。

请记住，您正在编写的实现可以以流式方式读取，它将通过管道传输到可写流。 highWaterMark 确保流不断流动，并且有效地使用用于保持该状态的内存。