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.

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,

Move PendingAssignment into a thread where blocking is acceptable.

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,