using System;

using System.Threading;

using System.Threading.Tasks;

public class Program

{

    public static void Main()

    {

        var source = new CancellationTokenSource();

        var token = source.Token;

        var app = new Program();

        var t = app.BrokerManager(token);

        t.Wait();

    }

    private void Log(string message)

    {

        Console.WriteLine("[Erro]: {0:yyyy-MM-dd hh:mm:ss} - {1}", DateTime.Now, message);

    }

    private async Task BrokerManager(CancellationToken cancellationToken)

    {

        try 

        {

            var timeOutSource = new CancellationTokenSource();

            timeOutSource.CancelAfter(1000);

            var timeOutToken = timeOutSource.Token;

            timeOutToken.Register(()=> { Log("Time out"); });

            var source = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, timeOutToken);

            var token = source.Token;

            await BrokerHandle(token);

        }

        catch(Exception ex)

        {

            Log(ex.ToString());

        }

    }

    private async Task BrokerHandle(CancellationToken cancellationToken)

    {

        Console.WriteLine("Inicia Handler");

        await Task.Delay(1000);

        Console.WriteLine("Handler continua em execução");

        await Task.Delay(1000);

        Console.WriteLine("Finaliza Handler");

    }

}