Struct stack_queue::assignment::TaskAssignment

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

Assignment of a task range yet to be processed

Implementations

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

pub fn as_slices(&self) -> (&[TaskRef<T>], &[TaskRef<T>])

pub fn tasks(&self) -> impl Iterator<Item = &TaskRef<T>>

An iterator over the assigned task range

pub fn resolve_with_iter<I>(self, iter: I) -> CompletionReceipt<T>where I: IntoIterator<Item = T::Value>,

Resolve task assignment with an iterator where indexes align with tasks

pub fn map<F>(self, op: F) -> CompletionReceipt<T>where F: Fn(T::Task) -> T::Value + Sync,

Resolve task assignment by mapping each task into it’s respective value

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

Move TaskAssignment into a thread where blocking is acceptable

Trait Implementations

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

fn drop(&mut self)

Executes the destructor for this type.

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

impl<'a, T, const N: usize> Sync for TaskAssignment<'a, T, N>where T: TaskQueue,