C# 文件流在写/读操作完成之前不会阻塞

Question

我正在尝试编写一个类，它将文件从一个位置复制到另一个位置并报告进度。我遇到的问题是，当应用程序运行时，进度会立即从 0 到 100%，但文件仍在后台复制。

    public void Copy(string sourceFile, string destinationFile)
    {
        _stopWatch.Start();

        _sourceStream = new FileStream(srcName, FileMode.Open);
        _destinationStream = new FileStream(destName, FileMode.CreateNew);

        read();
        //On a 500mb file, execution will reach here in about a second.
    }

    private void read()
    {
        int i = _sourceStream.Read(_buffer, 0, bufferSize);

        _completedBytes += i;

        if (i != 0)
        {
            _destinationStream.Write(_buffer, 0, i);

            TriggerProgressUpdate();

            read();
        }
    }

    private void TriggerProgressUpdate()
    {
        if (OnCopyProgress != null)
        {
            CopyProgressEventArgs arg = new CopyProgressEventArgs();
            arg.CompleteBytes = _completedBytes;

            if (_totalBytes == 0)
                _totalBytes = new FileInfo(srcName).Length;

            arg.TotalBytes = _totalBytes;

            OnCopyProgress(this, arg);
        }
    }

似乎正在发生的事情是 FileStream 只是在操作系统中对操作进行排队，而不是阻塞直到读取或写入完成。

有没有什么方法可以禁用此功能而不造成巨大的性能损失？

附言。我正在使用测试源和目标变量，这就是它们与参数不匹配的原因。

谢谢 克雷格

Answer 1

我不认为它可以对读取操作进行排队...毕竟，您有一个字节数组，在读取调用后它会包含一些数据- 数据最好是正确的。可能只有写入操作被缓冲。

您可以尝试定期在输出流上调用 Flush...我不太清楚 Flush 在不同级别的缓存方面会走多远，但它可能会等到数据实际写入。编辑：如果您知道它是一个 FileStream，您可以调用 Flush(true) ，它将等待数据实际写入磁盘。

请注意，您不应该经常这样做，否则性能会受到严重影响。您需要平衡进度准确性的粒度与采取更多控制而不是让操作系统优化磁盘访问的性能损失。

我担心你在这里使用递归 - 在一个非常大的文件上，你很可能会无缘无故地因堆栈溢出而崩溃。 （CLR 有时可以优化尾递归方法，但并非总是如此）。我建议你改用循环。 IMO：这也更具可读性：

public void Copy()
{
    int bytesRead;
    while ((bytesRead = _sourceStream.Read(_buffer, 0, _buffer.Length)) > 0)
    {
        _destinationStream.Write(_buffer, 0, bytesRead);
        _completedBytes += bytesRead;
        TriggerProgressUpdate();
        if (someAppropriateCondition)
        {
            _destinationStream.Flush();
        }
    }
}

顺便说一句，我希望您在某个地方处理流。就我个人而言，如果可能的话，我会尽量避免使用一次性成员变量。有什么理由不能在 using 语句中使用局部变量吗？

Answer 2

经过调查，我发现在 FileStream 的构造函数中使用“FileOptions.WriteThrough”将禁用写入缓存。这使得我的进度能够正确报告。然而，它确实会影响性能，在 Windows 中复制需要 13 秒，在我的应用程序中需要 20 秒。我将尝试优化代码并调整缓冲区大小，看看是否可以加快速度。