Class TaskPool

Represents a pool of active tasks with a predefined capacity.

public class TaskPool

Inherited Members: object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Remarks

This class is not thread safe, it assumes the taks pool is managed from a single thread.

Constructs a task pool with a specified capacity.

public TaskPool(int maxConcurrentTasks, ILogger logger)

maxConcurrentTasks int: Indicates the maximum number of tasks accepted by the task pool.
logger ILogger: The ILogger used for logging.

Indicates whether the task pool is at capacity or not.

public int AvailableCapacity { get; }

Adds a new batch of tasks to the task pool.

public void Add(IEnumerable<TaskInfo> tasks)

tasks IEnumerable<TaskInfo>: The list of TaskInfo items to be added to the pool.

TaskPoolException: The exception raised when a task cannot be added to the pool (e.g., the task pool is at capacity).

Determines whether the task pool already has a running task for a specified payload id.

public bool HasRunningTaskForPayload(string payloadId)

bool: True if the task pool already has a running task for the specified payload, false otherwise.