// OrtizOL - xCSw - http://o...content-available-to-author-only...t.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.");
        }
    }
}