Struct jatsl::TaskManager

pub struct TaskManager<Context> {
    pub context: Context,
    // some fields omitted
}

Manager for tasks and jobs

Provides context, handles resource availability changes and graceful termination

Fields

context: Context

Implementations

impl<Context> TaskManager<Context>

pub fn new(
    task_id: usize,
    context: Context
) -> (Self, Receiver<ResourceStatus>, OneShotReceiver<()>, WatchSender<Option<()>>)

Create a new task manager for the given task and context

pub fn create_resource_handle(&self) -> TaskResourceHandle

Create a new resource handle to notify about resource state

pub fn termination_signal(&self) -> impl Future<Output = ()>

Future that completes when the job should gracefully shutdown

pub fn termination_signal_triggered(&self) -> bool

Check if the job should enter graceful shutdown

pub async fn ready(&self)

Function to indicate to the scheduler that this job is ready to fulfull its contract. This has no effect when called from within tasks.

Trait Implementations

impl<Context: Clone> Clone for TaskManager<Context>

fn clone(&self) -> TaskManager<Context>

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.