using System;

using System.Threading;

using System.Threading.Tasks;

using System.Linq;

​

public class Program

{

    public static void Main()

    {

        CancellationTokenSource cts = new CancellationTokenSource(1000);

        cts.Token.Register(() => Console.WriteLine("--Token Canceled"));

        try

        {

            Enumerable.Range(1, 20)

                .AsParallel()

                .WithDegreeOfParallelism(2)

                .WithCancellation(cts.Token)

                .ForAll(x =>

                {

                    Console.WriteLine($"Processing item #{x}");

                    Thread.Sleep(200);

                    //cts.Token.ThrowIfCancellationRequested();

                });

           Console.WriteLine($"The query was completed successfully");

        }

        catch (OperationCanceledException)

        {

            Console.WriteLine($"The query was canceled");

        }

    }

}