{"id":1162,"date":"2023-03-21T16:04:20","date_gmt":"2023-03-21T09:04:20","guid":{"rendered":"https:\/\/csharptutorial.net\/?page_id=1162"},"modified":"2023-03-21T16:04:29","modified_gmt":"2023-03-21T09:04:29","slug":"csharp-cancellationtokensource","status":"publish","type":"page","link":"https:\/\/www.csharptutorial.net\/csharp-concurrency\/csharp-cancellationtokensource\/","title":{"rendered":"C# CancellationTokenSource"},"content":{"rendered":"\n

Summary<\/strong>: in this tutorial, you’ll learn how to use C# CancellationTokenSource<\/code> to cancel an asynchronous operation.<\/p>\n\n\n\n

Cancellation is cooperative<\/h2>\n\n\n\n

In .NET, cancellation is cooperative. It means that when you request to cancel an asynchronous operation, it’s up to the code running that operation to check whether cancellation has been requested and stop running if it has.<\/p>\n\n\n\n

Also, cancellation is not something that is automatically enforced by .NET, but rather a mechanism that you have to implement manually in your code using a CancellationToken<\/code> object.<\/p>\n\n\n\n

In other words, if you want an asynchronous operation to be cancellable, in the operation, you need to explicitly check for cancellation requests using the IsCancellationRequested<\/code> property of the CancellationToken<\/code> object, and stop running if it returns true<\/code>.<\/p>\n\n\n\n

To create an CancellationToken<\/code>, you use the CancellationTokenSource<\/code> class.<\/p>\n\n\n\n

How to use CancellationTokenSource class<\/h2>\n\n\n\n

Here are the steps for using the CancellationTokenSource<\/code> class:<\/p>\n\n\n\n

First, create a new CancellationTokenSource<\/code> object that can be used to generate a cancellation token:<\/p>\n\n\n

var<\/span> cts = new<\/span> CancellationTokenSource();<\/code><\/span>Code language:<\/span> C#<\/span> (<\/span>cs<\/span>)<\/span><\/small><\/pre>\n\n\n
Second, pass the cancellation token to an asynchronous operation:<\/p>\n\n\n
AsyncOperation(cts.Token);<\/code><\/span>Code language:<\/span> C#<\/span> (<\/span>cs<\/span>)<\/span><\/small><\/pre>\n\n\n
Third, check for cancellation requests in the asynchronous operation and stop running if the cancellation has been requested:<\/p>\n\n\n
Task<T> AsyncOperation<\/span>(CancellationToken cancellationToken<\/span>)<\/span>\n{\n    while<\/span> (!cancellationToken.IsCancellationRequested)\n    {\n        \/\/ Do some work...<\/span>\n    }\n\n    \/\/ The operation was cancelled...<\/span>\n}<\/code><\/span>Code language:<\/span> C#<\/span> (<\/span>cs<\/span>)<\/span><\/small><\/pre>\n\n\n
Finally, signal cancellation using the Cancel() method of the CancellationTokenSource<\/code> object:<\/p>\n\n\n
cts.Cancel();<\/code><\/span>Code language:<\/span> C#<\/span> (<\/span>cs<\/span>)<\/span><\/small><\/pre>\n\n\n
C# CancellationTokenSource example<\/h2>\n\n\n
using<\/span> static<\/span> System.Console;\n\nstatic<\/span> List<int<\/span>> Square<\/span>(int<\/span> max, CancellationToken token<\/span>)<\/span>\n{\n    var<\/span> result = new<\/span> List<int<\/span>>();\n    for<\/span> (int<\/span> i = 0<\/span>; i < max; i++)\n    {\n        Thread.Sleep(500<\/span>);\n\n        if<\/span> (token.IsCancellationRequested)\n        {\n            WriteLine(\"Cancellation requested!!!\"<\/span>);\n            token.ThrowIfCancellationRequested();\n            break<\/span>;\n        }\n\n        var<\/span> square = i * i;\n\n        WriteLine(square);\n        result.Add(square);\n    }\n    return<\/span> result;\n}\n\nCancellationTokenSource cts = new<\/span>();\n\nvar<\/span> task = Task.Run(() => Square(10<\/span>, cts.Token));\ntask.ContinueWith((t) =>\n{\n    var<\/span> squares = t.Result;\n    WriteLine(\"The square numbers are\"<\/span>);\n    foreach<\/span> (var<\/span> square in<\/span> squares)\n    {\n        Write($\"{square}<\/span> \"<\/span>);\n    }\n}, TaskContinuationOptions.OnlyOnRanToCompletion);\n\n\nWriteLine(\"Press 'c' to cancel.\"<\/span>);\nwhile<\/span> (true<\/span>)\n{\n    var<\/span> keyInfo = ReadKey(true<\/span>);\n    if<\/span> (keyInfo.KeyChar == 'c'<\/span>)\n    {\n        if<\/span> (task.Status == TaskStatus.Running)\n        {\n            cts.Cancel();\n            WriteLine(\"Canceling the task...\"<\/span>);\n            break<\/span>;\n        }\n    }\n    \/\/ quit if the task has been completed<\/span>\n    if<\/span> (task.Status == TaskStatus.RanToCompletion)\n    {\n        break<\/span>;\n    }\n}\n<\/code><\/span>Code language:<\/span> C#<\/span> (<\/span>cs<\/span>)<\/span><\/small><\/pre>\n\n\n
Output:<\/p>\n\n\n
Press 'c' to cancel.\n0\n1\n4\n9\n16\n25\nCanceling the task...<\/code><\/span>Code language:<\/span> plaintext<\/span> (<\/span>plaintext<\/span>)<\/span><\/small><\/pre>\n\n\n
How it works.<\/p>\n\n\n\n
First, create a CancellationTokenSource<\/code> object.<\/p>\n\n\n
CancellationTokenSource cts = new<\/span>();<\/code><\/span>Code language:<\/span> C#<\/span> (<\/span>cs<\/span>)<\/span><\/small><\/pre>\n\n\n
Second, create a new task that executes the Square()<\/code> method:<\/p>\n\n\n
var<\/span> task = Task.Run(() => Square(10<\/span>, cts.Token));<\/code><\/span>Code language:<\/span> C#<\/span> (<\/span>cs<\/span>)<\/span><\/small><\/pre>\n\n\n
The Square()<\/code> method returns a list of square numbers based on the argument. For example, if you pass 10 to the Square()<\/code> method, it’ll return a list of square numbers of 1, 2, 3, … 9, which are 2, 4, 9, … 81. Also, we pass a CancellationToken<\/code> to the Square()<\/code> method.<\/p>\n\n\n\n
Third, define the Square()<\/code> method that returns a list of square numbers. The Square()<\/code> method uses the CancellationToken<\/code> object to check if the cancellation has been requested. If yes, it calls token.ThrowIfCancellationRequested()<\/code> method to raise an OperationCanceledException<\/code> and exit the loop.<\/p>\n\n\n\n
Fourth, create a continuation that runs only if the task is running to the completion:<\/p>\n\n\n
task.ContinueWith((t) =>\n{\n    var<\/span> squares = t.Result;\n    WriteLine(\"The square numbers are\"<\/span>);\n    foreach<\/span> (var<\/span> square in<\/span> squares)\n    {\n        Write($\"{square}<\/span> \"<\/span>);\n    }\n}, TaskContinuationOptions.OnlyOnRanToCompletion);<\/code><\/span>Code language:<\/span> C#<\/span> (<\/span>cs<\/span>)<\/span><\/small><\/pre>\n\n\n
Fifth, create a loop that checks if the user presses the letter c<\/code> and sends a cancellation using the Cancel()<\/code> method of the CancellationTokenSource<\/code> object and exit the loop. Also, if the task status is RanToCompletion<\/code>, then exit the loop:<\/p>\n\n\n
WriteLine(\"Press 'c' to cancel.\"<\/span>);\nwhile<\/span> (true<\/span>)\n{\n    var<\/span> keyInfo = ReadKey(true<\/span>);\n    if<\/span> (keyInfo.KeyChar == 'c'<\/span>)\n    {\n        if<\/span> (task.Status == TaskStatus.Running)\n        {\n            cts.Cancel();\n            WriteLine(\"Canceling the task...\"<\/span>);\n            break<\/span>;\n        }\n    }\n    \/\/ quit if the task has been completed<\/span>\n    if<\/span> (task.Status == TaskStatus.RanToCompletion)\n    {\n        break<\/span>;\n    }\n}<\/code><\/span>Code language:<\/span> C#<\/span> (<\/span>cs<\/span>)<\/span><\/small><\/pre>\n\n\n
Summary<\/h2>\n\n\n\n
    \n
  • Use C# CancellationTokenSource<\/code> to cancel an asynchronous operation executed by a task.<\/li>\n<\/ul>\n
    \n\t
    \n\t\t
    Was this tutorial helpful ?<\/div>\n\t\t
    \n\t\t\t\n\t\t\t\t\n\t\t\t\t\t<\/path>\n\t\t\t\t<\/svg>\n\t\t\t\t Yes <\/span>\n\t\t\t<\/button>\n\n\t\t\t\n\t\t\t\t\n\t\t\t\t\t<\/path>\n\t\t\t\t<\/svg>\n\t\t\t\t No <\/span>\n\t\t\t<\/button>\n\t\t<\/div>\n\t<\/header>\n\n\t
    \n\t\t
    \n\t\t\t
    <\/div>\n\t\t\t\n\t\t\t