21.183. Class TaskQueueBase

Namespace: ArmoniK.Core.Common.Pollster
Assembly: ArmoniK.Core.Common.dll

Queue to send from a single producer to a consumer.

public abstract class TaskQueueBase : RendezvousChannel<TaskHandler>

21.183.1. Inheritance

object ← RendezvousChannel<TaskHandler> ← TaskQueueBase

21.183.2. Derived

PostProcessingTaskQueue, RunningTaskQueue

21.183.3. Inherited Members

RendezvousChannel<TaskHandler>.IsReaderClosed, RendezvousChannel<TaskHandler>.IsWriterClosed, RendezvousChannel<TaskHandler>.WriteAsync(TaskHandler, TimeSpan, CancellationToken), RendezvousChannel<TaskHandler>.ReadAsync(TimeSpan, CancellationToken), RendezvousChannel<TaskHandler>.CloseReader(), RendezvousChannel<TaskHandler>.CloseWriter(), RendezvousChannel<TaskHandler>.WaitForReader(TimeSpan, CancellationToken), RendezvousChannel<TaskHandler>.WaitForWriter(TimeSpan, CancellationToken), object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.MemberwiseClone(), object.ReferenceEquals(object?, object?), object.ToString()

21.183.4. Remarks

When a producer writes a task handler, it will wait for a consumer to read the task handler.

If the producer successfully writes to the queue, the consumer is guaranteed to have successfully read from the queue.

If the producer fails to write to the queue, the consumer is guaranteed to not have read the poduced the task handler.