Struct ProcessRegistry 

pub struct ProcessRegistry { /* private fields */ }

Registry for tracking spawned child processes.

Maintains a mapping of PIDs to task names, allowing for graceful shutdown of all child processes when the application is terminated.

Implementations

impl ProcessRegistry

pub fn new() -> Self

Creates a new empty process registry.

pub async fn register(&self, pid: u32, task_name: String)

Registers a process with the given PID and task name.

Call this immediately after spawning a child process.

pub async fn unregister(&self, pid: u32)

Unregisters a process after it has completed.

Call this after successfully waiting for the process to exit.

pub async fn count(&self) -> usize

Returns the number of currently tracked processes.

pub async fn terminate_all(&self, timeout: Duration)

Terminates all registered processes gracefully.

This method:

1. Sends SIGTERM to all process groups (allowing graceful shutdown)
2. Waits up to timeout for processes to exit
3. Sends SIGKILL to any remaining processes

On Unix, signals are sent to the entire process group (-pid) to ensure child processes spawned by tasks are also terminated.

Trait Implementations

impl Default for ProcessRegistry

fn default() -> Self

Returns the “default value” for a type.