using System;

​

using System.Data.SqlClient;

using System.Diagnostics;

using System.Threading;    

​

    public class Program {

        private static void Main(string[] args) {

            var worker = new Worker();

            worker.Do();

​

            Console.ReadLine();

        }

    }

​

    public class Worker {

        public async void Do() {

            var w = new Stopwatch();

            var ts = new CancellationTokenSource(TimeSpan.FromSeconds(5));

            var con = new SqlConnection(@"Server=.\SQLEXPRESS;Database=Test;Integrated Security=True;");

            try {

                con.Open();

                var command = new SqlCommand("WAITFOR DELAY '00:01'", con);

                try {

                    w.Start();

                    await command.ExecuteReaderAsync(ts.Token);

                }

                catch (SqlException e) {

                    w.Stop();

                    Console.WriteLine("Cancelled:" + w.Elapsed);

                    Console.WriteLine("Cancelled:" + e.Message);

                }

            }

            finally {

                con.Dispose();

            }

        }

    }