Struct TaskItemBuilder

pub struct TaskItemBuilder<'threads, T>
where
    T: Debug + Send + Sync + 'threads,
{ /* private fields */ }

Builder for TaskItem.

Implementations

impl<'threads, T> TaskItemBuilder<'threads, T>

where T: Debug + Send + Sync + 'threads,

pub fn node_idx<VALUE: Into<usize>>(self, value: VALUE) -> Self

Which node index to run

pub fn permit<VALUE: Into<Option<OwnedSemaphorePermit>>>( self, value: VALUE, ) -> Self

The concurrency permit

pub fn network<VALUE: Into<Arc<AsyncMutex<Network<T>>>>>( self, value: VALUE, ) -> Self

The network

pub fn shared_in_degs<VALUE: Into<Arc<AsyncMutex<Vec<usize>>>>>( self, value: VALUE, ) -> Self

Shared in-degrees

pub fn output_tx<VALUE: Into<Option<StreamingOutputSender<T>>>>( self, value: VALUE, ) -> Self

If streaming is enabled

pub fn checkpoint_cb<VALUE: Into<Option<Arc<dyn CheckpointCallback>>>>( self, value: VALUE, ) -> Self

Checkpoint callback

pub fn child_nodes_tx<VALUE: Into<Sender<usize>>>(self, value: VALUE) -> Self

Freed children => push to this channel

pub fn completed_nodes<VALUE: Into<SharedCompletedNodes>>( self, value: VALUE, ) -> Self

Completed

pub fn ready_nodes_tx<VALUE: Into<Sender<usize>>>(self, value: VALUE) -> Self

Freed children => we used to put them in child_nodes_tx, but we actually want them to go into ready_nodes_tx

pub fn threads_lifetime<VALUE: Into<PhantomData<&'threads ()>>>( self, value: VALUE, ) -> Self

pub fn build(self) -> Result<TaskItem<'threads, T>, TaskItemBuilderError>

Builds a new TaskItem.

Errors

If a required field has not been initialized.

Trait Implementations

impl<'threads, T> Default for TaskItemBuilder<'threads, T>

where T: Debug + Send + Sync + 'threads,

fn default() -> Self

Returns the “default value” for a type.