Best way in .NET to manage queue of tasks on a separate (single) thread

by

To create an asynchronous single degree of parallelism queue of work you can simply create a SemaphoreSlim, initialized to one, and then have the enqueing method await on the acquisition of that semaphore before starting the requested work.

public class TaskQueue
{
    private SemaphoreSlim semaphore;
    public TaskQueue()
    {
        semaphore = new SemaphoreSlim(1);
    }

    public async Task<T> Enqueue<T>(Func<Task<T>> taskGenerator)
    {
        await semaphore.WaitAsync();
        try
        {
            return await taskGenerator();
        }
        finally
        {
            semaphore.Release();
        }
    }
    public async Task Enqueue(Func<Task> taskGenerator)
    {
        await semaphore.WaitAsync();
        try
        {
            await taskGenerator();
        }
        finally
        {
            semaphore.Release();
        }
    }
}

Of course, to have a fixed degree of parallelism other than one simply initialize the semaphore to some other number.

More Related Contents:

  1. How to limit the amount of concurrent async I/O operations?
  2. Running multiple async tasks and waiting for them all to complete
  3. Task sequencing and re-entracy
  4. Enforce an async method to be called once
  5. .NET Asynchronous stream read/write
  6. Executing tasks in parallel
  7. Use Task.Run() in synchronous method to avoid deadlock waiting on async method?
  8. A pattern for self-cancelling and restarting task
  9. What is the correct way to cancel an async operation that doesn’t accept a CancellationToken?
  10. ForEachAsync with Result
  11. Converting async/await to Task.ContinueWith
  12. ConcurrentDictionary GetOrAdd async
  13. Catch an exception thrown by an async void method
  14. Should I avoid ‘async void’ event handlers?
  15. Using async/await for multiple tasks
  16. Fire and forget async method in asp.net mvc
  17. What is the best way to catch exception in Task?
  18. When should TaskCompletionSource be used?
  19. Best way to convert callback-based async method to awaitable task
  20. ConfigureAwait pushes the continuation to a pool thread
  21. How can I prevent synchronous continuations on a Task?
  22. Why does the async keyword exist
  23. Async/Await – is it *concurrent*?
  24. Async always WaitingForActivation
  25. Horrible performance using SqlCommand Async methods with large data
  26. How to throttle multiple asynchronous tasks?
  27. Best way to limit the number of active Tasks running via the Parallel Task Library
  28. Await and SynchronizationContext in a managed component hosted by an unmanaged app
  29. How to implement Task.WhenAny() with a predicate
  30. Create a completed Task

Leave a Comment