Correct way to delay the start of a Task

by

Like Damien_The_Unbeliever mentioned, the Async CTP includes Task.Delay. Fortunately, we have Reflector:

public static class TaskEx
{
    static readonly Task _sPreCompletedTask = GetCompletedTask();
    static readonly Task _sPreCanceledTask = GetPreCanceledTask();

    public static Task Delay(int dueTimeMs, CancellationToken cancellationToken)
    {
        if (dueTimeMs < -1)
            throw new ArgumentOutOfRangeException("dueTimeMs", "Invalid due time");
        if (cancellationToken.IsCancellationRequested)
            return _sPreCanceledTask;
        if (dueTimeMs == 0)
            return _sPreCompletedTask;

        var tcs = new TaskCompletionSource<object>();
        var ctr = new CancellationTokenRegistration();
        var timer = new Timer(delegate(object self)
        {
            ctr.Dispose();
            ((Timer)self).Dispose();
            tcs.TrySetResult(null);
        });
        if (cancellationToken.CanBeCanceled)
            ctr = cancellationToken.Register(delegate
                                                 {
                                                     timer.Dispose();
                                                     tcs.TrySetCanceled();
                                                 });

        timer.Change(dueTimeMs, -1);
        return tcs.Task;
    }

    private static Task GetPreCanceledTask()
    {
        var source = new TaskCompletionSource<object>();
        source.TrySetCanceled();
        return source.Task;
    }

    private static Task GetCompletedTask()
    {
        var source = new TaskCompletionSource<object>();
        source.TrySetResult(null);
        return source.Task;
    }
}

More Related Contents:

  1. Asynchronously wait for Task to complete with timeout
  2. Awaiting multiple Tasks with different results
  3. Running multiple async tasks and waiting for them all to complete
  4. Using async/await for multiple tasks
  5. StaTaskScheduler and STA thread message pumping
  6. TAP global exception handler
  7. What is the best way to catch exception in Task?
  8. Regarding usage of Task.Start() , Task.Run() and Task.Factory.StartNew()
  9. When should TaskCompletionSource be used?
  10. No ConcurrentList in .Net 4.0?
  11. Best way in .NET to manage queue of tasks on a separate (single) thread
  12. Task sequencing and re-entracy
  13. How to use non-thread-safe async/await APIs and patterns with ASP.NET Web API?
  14. Enforce an async method to be called once
  15. Is there anything like asynchronous BlockingCollection?
  16. Cancelling a pending task synchronously on the UI thread
  17. What is the use for Task.FromResult in C#
  18. Create a completed Task
  19. ConfigureAwait pushes the continuation to a pool thread
  20. How can I prevent synchronous continuations on a Task?
  21. How to achieve remove_if functionality in .NET ConcurrentDictionary
  22. Executing tasks in parallel
  23. Task.Factory.StartNew with async lambda and Task.WaitAll
  24. A pattern for self-cancelling and restarting task
  25. What is the correct way to cancel an async operation that doesn’t accept a CancellationToken?
  26. .Net TPL: Limited Concurrency Level Task scheduler with task priority?
  27. The lack of non-capturing Task.Yield forces me to use Task.Run, why follow that?
  28. Best way to limit the number of active Tasks running via the Parallel Task Library
  29. Task chaining (wait for the previous task to completed)
  30. Create a completed Task

Leave a Comment