Configure the queue length and task tracking settings in your application:

{
  "Background": {
    "QueueLength": 5000,
    "LockCounts": false,
    "Log": false
  }
}

• QueueLength: Defines the maximum number of tasks in the queue.
• LockCounts: Enables thread-safe counting of running tasks.
• Log: Outputs task tracking information to ILogger

Initializing the Queue

To use BackgroundQueue, you probably want to inject it via your constructor:

IBackgroundQueue _queue;

void MyClass(IBackgroundQueue queue)
{
    _queue = queue;
}

Queueing Tasks

Queuing a ValueTask

Rather than wrapping the task, you can elide it directly to avoid an extra state machine:

await _queue.QueueValueTask(_ => someValueTask(), cancellationToken);

Queuing a Task

Similarly, for Task:

await _queue.QueueTask(_ => someTask(), cancellationToken);

Waiting for Queue to Empty

To ensure all queued tasks finish before proceeding:

await queue.WaitUntilEmpty(cancellationToken);

Task Tracking

The queue tracks:

• The number of active ValueTask and Task instances.
• Whether any tasks are still processing.

To check if tasks are running:

bool isProcessing = await queueInformationUtil.IsProcessing(cancellationToken);

To get current task counts:

var (taskCount, valueTaskCount) = await queueInformationUtil.GetCountsOfProcessing(cancellationToken);