Struct stack_queue::assignment::PendingAssignment

pub struct PendingAssignment<'a, T: TaskQueue, const N: usize> { /* private fields */ }

The responsibilty to process a yet to be assigned set of tasks on the queue.

Implementations

impl<'a, T, const N: usize> PendingAssignment<'a, T, N>where
    T: TaskQueue,

pub fn into_assignment(self) -> TaskAssignment<'a, T, N>

By converting into a TaskAssignment the task range responsible for processing will be bounded and further tasks enqueued will be of a new batch. Assignment of a task range can be deferred until resources such as database connections are ready as a way to process tasks in larger batches. This operation is constant time and wait-free

pub async fn with_blocking<F>(self, f: F) -> CompletionReceipt<T>where
    F: for<'b> FnOnce(PendingAssignment<'b, T, N>) -> CompletionReceipt<T> + Send + 'static,

Resolve task assignment within a thread where blocking is acceptable. If the runtime would otherwise shutdown, instead it will suspend for the lifetime of this thread as to protect the underlying thread local data from being destroyed

Trait Implementations

impl<'a, T, const N: usize> Drop for PendingAssignment<'a, T, N>where
    T: TaskQueue,

fn drop(&mut self)

Executes the destructor for this type.

impl<'a, T, const N: usize> Send for PendingAssignment<'a, T, N>where
    T: TaskQueue,

impl<'a, T, const N: usize> Sync for PendingAssignment<'a, T, N>where
    T: TaskQueue,
    <T as TaskQueue>::Task: Sync,