Struct Runner

Source

pub struct Runner {
    pub jobs: Vec<Box<dyn Job>>,
    pub thread: Option<JoinHandle<()>>,
    pub running: bool,
    pub tx: Option<UnboundedSender<Result<(), ()>>>,
    pub working: Arc<AtomicBool>,
}

Expand description

Runner that will hold all the jobs and will start up the execution and eventually will stop it.

Fields§

§jobs: Vec<Box<dyn Job>>

the current jobs

§thread: Option<JoinHandle<()>>

the task that is running the handle

§running: bool

is the task running or not

§tx: Option<UnboundedSender<Result<(), ()>>>

channel sending message

§working: Arc<AtomicBool>

tracker to determine crons working

Implementations§

Source §

impl Runner

Source

pub fn new() -> Self

Create new runner

Examples found in repository ?

examples/example.rs (line 21)

20async fn run() {
21    let mut runner = Runner::new();
22    println!("Adding ExampleJob to the Runner");
23    runner = runner.add(Box::new(ExampleJob));
24    println!("Starting the Runner for 20 seconds");
25    runner = runner.run().await;
26    tokio::time::sleep(Duration::from_millis(20 * 1000)).await;
27    println!("Stopping the Runner");
28    runner.stop().await;
29}

Source

pub fn add(self, job: Box<dyn Job>) -> Self

Add jobs into the runner

Does nothing if already running.

Examples found in repository ?

examples/example.rs (line 23)

20async fn run() {
21    let mut runner = Runner::new();
22    println!("Adding ExampleJob to the Runner");
23    runner = runner.add(Box::new(ExampleJob));
24    println!("Starting the Runner for 20 seconds");
25    runner = runner.run().await;
26    tokio::time::sleep(Duration::from_millis(20 * 1000)).await;
27    println!("Stopping the Runner");
28    runner.stop().await;
29}

Source

pub fn jobs_to_run(&self) -> usize

Number of jobs ready to start running

Source

pub async fn run(self) -> Self

Start the loop and job execution

Examples found in repository ?

examples/example.rs (line 25)

20async fn run() {
21    let mut runner = Runner::new();
22    println!("Adding ExampleJob to the Runner");
23    runner = runner.add(Box::new(ExampleJob));
24    println!("Starting the Runner for 20 seconds");
25    runner = runner.run().await;
26    tokio::time::sleep(Duration::from_millis(20 * 1000)).await;
27    println!("Stopping the Runner");
28    runner.stop().await;
29}

Source

pub async fn stop(&mut self)

Stop the spawned runner

Examples found in repository ?

examples/example.rs (line 28)

20async fn run() {
21    let mut runner = Runner::new();
22    println!("Adding ExampleJob to the Runner");
23    runner = runner.add(Box::new(ExampleJob));
24    println!("Starting the Runner for 20 seconds");
25    runner = runner.run().await;
26    tokio::time::sleep(Duration::from_millis(20 * 1000)).await;
27    println!("Stopping the Runner");
28    runner.stop().await;
29}