FileStream.EndWrite 引发异常 (.NET)

Question

我正在尝试在复制文件时实现进度通知机制。 我按以下方式执行此操作：

1. 我创建两个 FileStreams - 用于读取和写入
2. 调用 BeginRead 向其传递一个 ReadCallback 以及一个包含读取流和数组来填充从文件中读取的数据。
3. 在 ReadCallback 中，我调用 EndRead 方法，并在用于写入的文件流上调用 BeginWrite 方法，并将其传递给 WriteCallback< /strong> 和一个包含流（用于写入）和要写入的数组（与读取部分相同）的结构。
4. 当我在 WriteCallback 中调用 EndWrite 并将 asyncResult 传递给它时，它会抛出一个 ArgumentException: 要么 IAsyncResult 对象不是来自此类型的相应异步方法，或 EndRead 使用相同的 IAsyncResult 被多次调用

请帮助解决此问题。

更新源代码：

private void StartAsyncCopying()
{
    var sourceFileInfo = new FileInfo(Source);
    if (!sourceFileInfo.Exists)
    {
        throw new FileNotFoundException("File not found.",
            Source);
    }
    m_sourceLength = sourceFileInfo.Length;
    m_readerStream = new FileStream(Source, FileMode.Open);
    m_writerStream = new FileStream(Target, FileMode.Create);
    m_queueBuffer = new Queue<byte[]>(DefaultQueueBufferSize);
    m_queueBufferLock = new object();

    ProgressRead();
}

private void ProgressRead()
{
    var readerChunck = new byte[DefaultChunckSize];
    var streamChunck = new StreamChunck(readerChunck, m_readerStream);
    m_readerStream.BeginRead(streamChunck.Chunck,
        0,
        streamChunck.Chunck.Length,
        ReadCallback,
        streamChunck);
}


private void ReadCallback(IAsyncResult asyncResult)
{
    var streamChunck = asyncResult.AsyncState as StreamChunck;
    var numberOfBytesRead = streamChunck.Stream.EndRead(asyncResult);

    m_readerOffset += numberOfBytesRead;

    ProgressWrite(streamChunck.Chunck);
}

private void ProgressWrite(byte[] chunck)
{
    var streamChunck = new StreamChunck(chunck, m_writerStream);
    m_writerAsyncResult = m_writerStream.BeginWrite(streamChunck.Chunck,
        0,
        streamChunck.Chunck.Length,
        WriteCallback,
        streamChunck);
}

private void WriteCallback(IAsyncResult asyncResult)
{
    var streamChunck = asyncResult.AsyncState as StreamChunck;
    var numberOfBytesWritten = streamChunck.Stream.EndRead(asyncResult);
    m_writerOffset += numberOfBytesWritten;

    var progressChangedEventArgs = new CopyProgressChangedEventArgs(m_operationDescription,
        m_sourceLength,
        m_writerOffset);
    OnCopyProgressChanged(progressChangedEventArgs);

    if (m_writerOffset == m_sourceLength)
    {
        var copyCompletedEventArgs = new CopyCompletedEventArgs(m_operationDescription, null);
        OnCopyCompleted(copyCompletedEventArgs);
    }
    else
    {
        ProgressRead();
    }
}

Answer 1

当您调用 BeginXXX 时，您可能会得到一个 IAsyncResult 对象，要调用 EndXXX，您需要传递此 IAsyncResult 引用进入方法。如果您在读取中使用了相同的对象并将其传递到写入中，则它将不起作用 - 在您的场景中将有两个单独的 IAsyncResult 对象。

当我这样做时，我将对返回的 IAsyncResult 的引用保留为本地类变量（如果使用回调）。当我调用 EndXXX 时，我提供此本地引用（从我最初的 BeginXXX 获得），然后将其置空以表示它可以重用。

更新2：看看你的代码，WriteCallback中应该是EndWrite的实际上是一个EndRead，野餐错误： -)

更新 1： 以下内容对我来说效果很好......

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;

namespace ConsoleApplication14
{
    class Program
    {
        static FileStream fs = null;
        static MemoryStream ms = null;
        static byte[] buffer = new byte[512];

        static void Main(string[] args)
        {
            fs = new FileStream("theFile", FileMode.Open);
            fs.BeginRead(buffer, 0, 512, new AsyncCallback(ReadFinished), null);

            Console.Read();
        }

        static void ReadFinished(IAsyncResult res)
        {
            fs.EndRead(res);
            fs.Dispose();

            ms = new MemoryStream();
            ms.BeginWrite(buffer, 0, 512, new AsyncCallback(WriteFinished), null);
        }

        static void WriteFinished(IAsyncResult res)
        {
            ms.EndWrite(res);
            ms.Dispose();
        }
    }
}

Answer 2

你有以下内容：

private void WriteCallback(IAsyncResult asyncResult)
{
    var streamChunck = asyncResult.AsyncState as StreamChunck;
    var numberOfBytesWritten = streamChunck.Stream.EndRead(asyncResult);
                                                   ^^^^^^^

但你正在写作。您不应该调用 EndWrite 吗？或者我错过了一些非常明显的东西？

该方法中还有一个 ProgressRead(); 。