任务取消

Question

我正在寻找一种方法来取消已经启动的任务，然后使用新的输入数据重新启动相同的任务。

以下是我编写的示例代码，但它不起作用。

private CancellationTokenSource _cancellationTokenSource;
public public async Task DoSomething(string input)
{
    _cancellationTokenSource.Cancel(true);
    _cancellationTokenSource = new CancellationTokenSource();
    try
    {

        Task.Run(async () =>
        {
            //Asynchronous method code here which uses input like database operations.
            await doSomeDataBaseOperationAsync(input);
        }, _cancellationTokenSource.Token);
    }
    catch { }
}

有人可以帮我吗？

Answer 1

您需要在您的方法doSomeDataBaseOperationAsync 中进行手动检查，该方法正在异步执行，如下面的代码 sn-p 所示。我通常做的方式是在方法本身开始时检查一次取消令牌源的状态。如果在那之前没有请求取消，那么继续执行整个函数体。

但是没有人可以阻止您在方法中更关键的时刻或里程碑进行检查，例如您可能还想在触发 DB 调用之前重新检查一次取消令牌状态。

注意事项：您只需要确保在方法执行期间多次进行此类检查并返回中途时，您不会离开对象的状态处于不一致的状态。如果您在这种方法中不更改类的任何成员变量，那么您应该很好。

private void doSomeDataBaseOperationAsync(input)
{
   if (_cancellationTokenSource.IsCancellationRequested)
     return; //stop any further processing.
   //do some processing and calculations on the client side
   //.....
   //.....
   //.....
   //make a check again before firing DB request
   if (_cancellationTokenSource.IsCancellationRequested)
     return; //stop any further processing.
   //Do database stuff. cancellation has not been requested. Process the DB request.
}