Не удается отменить задачу с помощью CancellationTokenSource.Cancel()

Question

У меня возникли проблемы с остановкой задачи. Во-первых, я только начал использовать Задачи. Раньше я использовал делегат.BeginInvoke() для работы в фоновом режиме, но на этот раз мне нужно остановить фоновое выполнение, если это необходимо. Поэтому я переключился на «Задачи». Это мой код:

CancellationTokenSource token = new CancellationTokenSource(); 
Task posting = Task.Factory.StartNew(() => DoPosting(docs, session), token.Token); 
HttpRuntime.Cache[session.ToString() + "_token"] = token; 
HttpRuntime.Cache[session.ToString() + "_task"] = posting; 

Это ASP.NET MVC, поэтому я храню долговечные вещи в HttpRuntime.Cache. Пользователь может отменить операцию с помощью этого действия:

public JsonResult StopPosting(string session) 
{ 
    CancellationTokenSource token = (CancellationTokenSource)HttpRuntime.Cache.Get(session.ToString() + "_token"); 
    Task posting = (Task)HttpRuntime.Cache[session.ToString() + "_task"]; 
    token.Cancel(); 

    return Json(new { Message = "Stopped!" }); 
} 

Теперь, когда это действие попадает в первый раз, ничего не происходит. Затем я запрашиваю отмену во второй раз. Теперь, token.IsCancellationRequested говорит «true», поэтому token.Cancel() должен что-то сделать. Но posting.Status все еще «работает». Он будет оставаться таким, пока он не завершится, а затем «RunToCompletion».

Итак, я попросил отменить задание, но он был отменен.

Возможно, я что-то делаю неправильно, или мне не хватает чего-то очевидного, но я просто не могу понять/понять, почему он не отменит.

Возможно, кто-то может пролить свет?

С уважением.

Answer 1

Отмена маркера не сразу приведет к тому, что делегат задачи прекратит выполнение прямо там, где он есть. Подтверждение того, что (как это делается через Abort через потоки), может вызвать всевозможные ошибки, начиная от объектов, которые не очищаются должным образом, нарушаются инварианты из-за выполнения, останавливая часть пути через операцию, которая должна быть логически замечена как атомарная и т. Д. .

Что вам нужно сделать, так это выполнить фактическую выполняемую функцию, посмотреть на CancellationToken и периодически проверять, что она не была отменена. В дополнение к передаче токена до StartNew вам необходимо передать его методу DoPosting. Затем этот метод должен периодически вызывать token.ThrowIfCancellationRequested(); в местах в методе, где было бы целесообразно остановиться, если бы действительно было исправлено аннулирование.

См. How do I cancel non-cancelable async operations? для дальнейшего ознакомления.

Answer 2

Я думаю, вы, вероятно, ожидаете слишком много CancellationToken. Что касается задач, я думаю, что CancellationToken используется только при определении того, следует ли запускать задачу, когда для этой задачи доступен слот. После запуска задачи структура задачи не может просто прервать вызов делегата, когда CancellationToken будет отменен. Чтобы полностью отменить что-то вроде этого, код, который вызывается инфраструктурой Task (DoPosting), должен быть написан, чтобы быть в курсе CancellationToken и должен проверять состояние этого токена непосредственно в соответствующих точках кода.