spawn-wait 0.2.2

Spawn and manage a set of processes each associated with a key, and wait on all or part of them simultaneously.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use std::process::Command;

use spawn_wait::{ProcessSet, SignalHandler, WaitAnyResult};

fn make_cmd(secs: i32) -> Command {
  let mut cmd = Command::new("sh");
  cmd.arg("-c");
  cmd.arg(format!(
    "echo Sleeping for {secs} seconds; sleep {secs}",
    secs = secs
  ));
  cmd
}

fn main() {
  let mut procs = ProcessSet::with_concurrency_limit(3);
  for i in 0..5 {
    procs.add_command((1, i), make_cmd(1));
  }
  for i in 0..5 {
    procs.add_command((2, i), make_cmd(2));
  }
  for i in 0..5 {
    procs.add_command((3, i), make_cmd(3));
  }

  let mut sh = SignalHandler::default();
  loop {
    match procs.wait_any(&mut sh) {
      WaitAnyResult::NoProcessesRunning => {
        println!("All done");
        return;
      }
      WaitAnyResult::ReceivedTerminationSignal(_) => {
        println!("Terminating");
        procs.sigint_all_and_wait(&mut sh).unwrap();
        return;
      }
      WaitAnyResult::Subprocess(id, r) => {
        println!("Process \"sleep {} # {}\" finished: {:?}", id.1, id.0, r);
      }
    }
  }
}