Использование CancellationToken для Task.Run

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(); 
    } 
} 

Если я называю TaskCancel() в TaskAction(), задача отменена исключение ловится.

Если я вызываю TaskCancel() вне объекта, отмененное исключение не будет обнаружено.

Вот код, чтобы показать, где отменено исключение не перехвачено:

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

Как я могу назвать TaskCancel() снаружи объекта, так что отмененное исключение перехватывается?

Answer 1

Отмена должна быть совместной. Task.Run не знает, какие побочные эффекты может иметь назначенный делегат, поэтому единственная логически безопасная точка, в которой Task.Run может проверить ваш CancellationToken и выбросить OCE (не выходя из приложения в потенциально несогласованном состоянии), - до, начинается операция async - после этого времени код пользователя проверяется на токен.

Проблема: ваш код пользователя тратит большую часть своего времени на ожидание 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"); 
    } 
} 

Я не могу вам сказать, будет ли это или нет производить исключение, указывающее, что операция была отменена - вам нужно попробовать и убедиться сами.