Struct PerThreadShutdown 

pub struct PerThreadShutdown { /* private fields */ }

Shutdown coordinator shared by every worker spawned via spawn_per_thread (and friends). Workers select! against Self::notified in their accept loop, so triggering PerThreadShutdown::trigger cleanly exits each worker’s loop { accept } instead of leaking the OS thread on shutdown.

Backed by a tokio_util::sync::CancellationToken so the signal is sticky: workers that register notified() after trigger() was called still observe the request immediately, fixing the Notify::notify_waiters race where late subscribers would miss the shutdown.

Also carries a private [BindStatus] that workers update with the result of their SO_REUSEPORT bind so the parent (e.g. serve_per_thread) can fail loudly on “every worker failed to bind” instead of returning Ok(()) — previously the function would await Ctrl+C indefinitely and then claim success even when no listener was up, a false health signal to supervisors.

Implementations

impl PerThreadShutdown

pub fn new() -> Self

Construct an unsignalled shutdown coordinator.

pub fn trigger(&self)

Notify every worker waiter that it should exit its accept loop. Idempotent — calling it more than once is a no-op.

pub async fn notified(&self)

Future a worker awaits to learn that shutdown has been requested.

pub async fn wait_for_bind_outcome(&self, total: usize) -> Result<()>

Wait until either at least one worker bound successfully, or all total workers reported a bind failure. Returns the first recorded io::Error in the all-failure case so the caller can propagate a real error instead of pretending the server started.

Trait Implementations

impl Clone for PerThreadShutdown

fn clone(&self) -> PerThreadShutdown

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for PerThreadShutdown

fn default() -> PerThreadShutdown

Returns the “default value” for a type.