对 Task.Run 使用 CancellationToken

Question

我有一些代码使用带有取消令牌的Task.Run。

这是我的代码：

public class TaskObject
{
    CancellationTokenSource _source = new CancellationTokenSource();
    public async Task TaskAction()
    {
        var task = Task.Run(async delegate
        {
            await TaskRun();
        }, _source.Token);

        //TaskCancel();

        try
        {
            task.Wait();
        }
        catch (Exception ex)
        {

        }
    }
    public async Task TaskRun()
    {
        if (_source.IsCancellationRequested)
        {
            _source.Token.ThrowIfCancellationRequested();
        }

        SpeechSynthesizer _speechSynthesizer = new SpeechSynthesizer();
        _speechSynthesizer.SpeakAsync("This is a test prompt");
    }
    public void TaskCancel()
    {
        _source.Cancel();
    }
}

如果我在TaskAction()中调用TaskCancel()，就会捕获到任务取消异常。

如果我从对象外部调用TaskCancel()，则不会捕获已取消的异常。

这里有一些代码来演示取消的异常没有被捕获：

taskObject = new TaskObject();
await taskObject.TaskAction();
taskObject.TaskCancel();

如何从对象外部调用TaskCancel() 以便捕获已取消的异常？

Answer 1

取消需要合作。 Task.Run 不知道计划委托可能产生的副作用，因此 Task.Run 可以检查您的 CancellationToken 并抛出 OCE（不会使您的应用程序处于潜在的不一致状态）的唯一逻辑安全点是 之前异步操作开始 - 在那之后由用户代码检查令牌。

问题是，您的用户代码大部分时间都在等待SpeechSynthesizer.SpeakAsync，它没有接受CancellationToken 的重载。

SpeechSynthesizer 确实有一个 SpeakAsyncCancelAll 方法，您可以像这样插入它：

public async Task TaskRun(CancellationToken ct)
{
    ct.ThrowIfCancellationRequested();

    SpeechSynthesizer _speechSynthesizer = new SpeechSynthesizer();

    using (ct.Register(() => _speechSynthesizer.SpeakAsyncCancelAll())) {
        await _speechSynthesizer.SpeakAsync("This is a test prompt");
    }
}

我无法告诉您这是否会产生异常指示操作已取消 - 您需要自己尝试查看。