杀死与文件流一起使用的任务的正确方法是什么

Question

我有一个并行任务，将一些数据写入文件

using (var lFileStream = File.Open(aDestinationFile, shouldResume ? FileMode.Append : FileMode.Create, FileAccess.Write))
{
    try
    {
        while ((lCount = lDownloadStream.Read(lBuf, 0, lBuf.Length)) > 0)
        {
            lFileStream.Write(lBuf, 0, lCount);
        }
    }
    finally
    {
        lFileStream.Close();
    }
}

我通过以下方式启动任务：

Task.Factory.StartNew(() => 
                {
                    try
                    {
                        myMethod();
                    }
                    catch (Exception ex)
                    {
                        Log.Exc(ex);
                    }
                }
            , _resetEvent.Token);

在某些情况下我必须终止任务：

_resetEvent.Cancel(false);
try
{
    _task.Dispose();
}
catch
{
}

任务停止后，我开始了一个新任务，但是当我尝试访问已使用的文件时，我得到了：

进程无法访问文件'bla-bla'，因为它正在被使用 由另一个进程。

我怎样才能正确地“杀死”任务？

Answer 1

当您将CancellationToken 传递给任务时，如果令牌在任务调度程序开始执行任务时被取消，那么所做的只是阻止任务启动。一旦任务已经启动，它对任务没有影响。

您需要做的是“合作取消”，您需要检查在任务内部运行的代码中的令牌，并让它取消正在执行的操作。最简单的方法是将 CancelationToken 传递给方法本身，然后运行函数 ThrowIfCancellationRequested();，您的程序将抛出 OperationCanceledException 并执行您设置的任何清理以处理该异常。

private void myMethod(CancellationToken token)
{
    using (var lFileStream = File.Open(aDestinationFile, shouldResume ? FileMode.Append : FileMode.Create, FileAccess.Write))
    {
        //The try-finally was not nessessary, Dispose() will call Close() for you.
        while ((lCount = lDownloadStream.Read(lBuf, 0, lBuf.Length)) > 0)
        {
            token.ThrowIfCancellationRequested();
            lFileStream.Write(lBuf, 0, lCount);
        }
    }
}

Task.Factory.StartNew(() => 
                {
                    try
                    {
                        myMethod(_resetEvent.Token);
                    }
                    catch (Exception ex)
                    {
                        //If the task was canceled we don't need to log the exception.
                        if(!ex is OperationCanceledException)
                            Log.Exc(ex);
                    }
                }
            , _resetEvent.Token);

---

为了减少重构，您可以对您的 writer 方法执行以下操作

//All your old code can still call this method.
public void myMethod()
{
    myMethod(CancellationToken.None); //Call the overload with a empty token.
}

//New code that needs to cancel the operation can call this method.
public void myMethod(CancellationToken token)
{
     //Slightly modified old Writer code that uses the CancelationToken inside any loops or in between any long running operations that can't be interrupted.
}