Struct spawn_wait::ProcessSet

pub struct ProcessSet<K> { /* private fields */ }

Implementations

impl<K> ProcessSet<K>

pub fn new() -> Self

pub fn with_concurrency_limit(limit: usize) -> Self

impl<K: Hash + Eq + Clone> ProcessSet<K>

pub fn add_command(&mut self, key: K, command: Command)

pub fn wait_any(
    &mut self,
    signal_handler: &mut SignalHandler
) -> WaitAnyResult<K>

Wait for any process to finish, and return the corrosponding key and resulting child (or error).

Takes in a signal handler from outside which can be created with SignalHandler::default(). This ensures that signals between waits are not missed.

If multiple processes have finished, this will only return one of them. Call this function in a loop to wait for all processes to finish.

If no process has finished, this will pause the current thread.

If there are no processes running, this will return NoProcessesRunning.

If, during the middle of waiting, the current process gets a SIGINT or SIGTERM, this will return ReceivedTerminationSignal(signal_number). More signals can be added via SignalHandler::add_termination_signal.

pub fn try_wait_any(&mut self) -> Option<WaitAnyResult<K>>

Non-blocking version of wait_any. If no process has finished, this will just return None.

Will never return WaitAnyResult::ReceivedTerminationSignal.

pub fn sigkill_all(&mut self) -> Result<()>

Kills all subprocesses.

pub fn sigint_all(&mut self) -> Result<()>

Send a SIGINT to all subprocesses and return immediately.

pub fn sigint_all_and_wait(
    &mut self,
    signal_handler: &mut SignalHandler
) -> Result<()>

Send a SIGINT to all subprocesses and wait for them to finish.

Trait Implementations

impl<K: Debug> Debug for ProcessSet<K>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<K> Default for ProcessSet<K>

fn default() -> Self

Returns the “default value” for a type.