22.182. Class RunningTaskProcessor
Namespace: ArmoniK.Core.Common.Pollster
Assembly: ArmoniK.Core.Common.dll
A background service that processes running tasks from a queue. It reads task handlers from the running task queue, executes them, and forwards completed tasks to the post-processing queue.
public class RunningTaskProcessor : BackgroundService, IHostedService, IDisposable
22.182.1. Inheritance
22.182.2. Implements
22.182.3. Inherited Members
BackgroundService.Dispose(), BackgroundService.ExecuteAsync(CancellationToken), BackgroundService.StartAsync(CancellationToken), BackgroundService.StopAsync(CancellationToken), BackgroundService.ExecuteTask, object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()
22.182.4. Constructors
22.182.4.1. RunningTaskProcessor(RunningTaskQueue, PostProcessingTaskQueue, ExceptionManager, ILogger<RunningTaskProcessor>)
Initializes a new instance of the
public RunningTaskProcessor(RunningTaskQueue runningTaskQueue, PostProcessingTaskQueue postProcessingTaskQueue, ExceptionManager exceptionManager, ILogger<RunningTaskProcessor> logger)
22.182.4.1.1. Parameters
runningTaskQueue RunningTaskQueue
The queue containing tasks ready for execution.
postProcessingTaskQueue PostProcessingTaskQueue
The queue where completed tasks are forwarded for post-processing.
exceptionManager ExceptionManager
The manager handling exceptions and cancellation.
logger ILogger<RunningTaskProcessor>
The logger for this class.
22.182.5. Methods
22.182.5.1. ExecuteAsync(CancellationToken)
This method is called when the
protected override Task ExecuteAsync(CancellationToken stoppingToken)
22.182.5.1.1. Parameters
stoppingToken CancellationToken
Triggered when
22.182.5.1.2. Returns
A
22.182.5.1.3. Remarks
See Worker Services in .NET for implementation guidelines.