CancelacionOperacionAsincronica.cs

// OrtizOL - xCSw - http://ortizol.blogspot.com

using System;
using System.Threading;

namespace Receta.CSharp.R0304
{
    public class CancelacionOperacionAsincronica
    {
        public static void Main()
        {
            Console.WriteLine(Environment.NewLine);

            // Primer enfoque: Comprobación de propiedad IsCancellationRequested:
            using (CancellationTokenSource cts = new CancellationTokenSource())
            {
                // Obtención de token para cancelación:
                CancellationToken token = cts.Token;

                // Ejecución de operación asincrónica en pool de threads:
                ThreadPool.QueueUserWorkItem( _ => OperacionAsincronica1(token));

                Thread.Sleep(TimeSpan.FromSeconds(2));

                // Emite notificación de cancelación:
                cts.Cancel();
            }

            // Segundo enfoque: Lanzamiento de excepción OperationCanceledException:
            using (CancellationTokenSource cts = new CancellationTokenSource())
            {
                CancellationToken token = cts.Token;

                ThreadPool.QueueUserWorkItem( _ => OperacionAsincronica2(token));

                Thread.Sleep(TimeSpan.FromSeconds(2));

                // Emite notificación de cancelación para generación
                // de la excepción OperationCanceledException:
                cts.Cancel();
            }

            // Tercer enfoque: Registro de callback para su invocación
            // cuando la operación sea cancelada:
            using (CancellationTokenSource cts = new CancellationTokenSource())
            {
                CancellationToken token = cts.Token;

                ThreadPool.QueueUserWorkItem( _ => OperacionAsincronica3(token));

                Thread.Sleep(TimeSpan.FromSeconds(2));

                cts.Cancel();
            }

            // Tiempo de espera adicional en Main:
            Thread.Sleep(TimeSpan.FromSeconds(2));

            Console.WriteLine(Environment.NewLine);
        }

        private static void OperacionAsincronica1(CancellationToken token)
        {
            Console.WriteLine ("Inicio operación asincrónica no. 1.");

            for (int i = 1; i <= 5; ++i)
            {
                if (token.IsCancellationRequested)
                {
                    Console.WriteLine ("La operación asincrónica no. 1 fue cancelada.");
                    return;
                }

                Thread.Sleep(TimeSpan.FromSeconds(1));
            }

            Console.WriteLine ("La operación asincrónica no. 1 finalizó correctamente.");
        }

        private static void OperacionAsincronica2(CancellationToken token)
        {
            try
            {
                Console.WriteLine ("Inicio operación asincrónica no. 2.");

                for (int i = 1; i <= 5; ++i)
                {
                    token.ThrowIfCancellationRequested();
                    Thread.Sleep(TimeSpan.FromSeconds(1));
                }

                Console.WriteLine ("La operación asincrónica no. 2 finalizó correctamente.");
            }
            catch(OperationCanceledException)
            {
                Console.WriteLine ("La operación asincrónica no. 2 ha sido cancelada.");
            }
        }

        private static void OperacionAsincronica3(CancellationToken token)
        {
            bool centinelaCancelacion = false;

            token.Register( () => centinelaCancelacion = true);

            Console.WriteLine ("Inicio operación asincrónica no. 3.");

            for(int i = 1; i <= 5; ++i)
            {
                if (centinelaCancelacion)
                {
                    Console.WriteLine ("La operación asincrónica no. 3 ha sido cancelada.");
                    return;
                }
                Thread.Sleep(TimeSpan.FromSeconds(1));
            }

            Console.WriteLine ("La operación asincrónica no. 3 finalizó correctamente.");
        }
    }
}