Struct ForkSafeRuntime 

pub struct ForkSafeRuntime { /* private fields */ }

Owns a tokio runtime and manages [PausableWorker]s on it.

Supports the full fork protocol (before_fork / after_fork_parent / after_fork_child) and synchronous shutdown.

Implementations

impl ForkSafeRuntime

pub fn with_worker_threads( worker_threads: usize, ) -> Result<Self, SharedRuntimeError>

Creates a ForkSafeRuntime with the given number of tokio worker threads.

pub fn before_fork(&self)

Pauses all workers before fork(). Worker pause errors are logged, not propagated.

pub fn after_fork_parent(&self) -> Result<(), SharedRuntimeError>

Restarts the runtime and workers in the parent after forking; worker state is preserved.

pub fn after_fork_child(&self) -> Result<(), SharedRuntimeError>

Reinitializes the runtime in the child after forking. Workers with restart_on_fork = true are reset and restarted; others are dropped without shutdown.

pub fn shutdown( &self, timeout: Option<Duration>, ) -> Result<(), SharedRuntimeError>

Shuts down all workers synchronously. Returns ShutdownTimedOut if timeout is exceeded.

Trait Implementations

impl BlockingRuntime for ForkSafeRuntime

fn block_on<F: Future>(&self, f: F) -> Result<F::Output, Error>

Falls back to a temporary current-thread runtime in the fork window.

fn block_on_with_timeout<F: Future>( &self, f: F, timeout: Duration, ) -> Result<F::Output, BlockOnTimeoutError>

Drives f to completion, blocking the current thread, but gives up once timeout elapses.

impl Debug for ForkSafeRuntime

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

Formats the value using the given formatter.

impl SharedRuntime for ForkSafeRuntime

fn new() -> Result<Self, SharedRuntimeError>

Creates a new instance of the runtime with default configuration.

fn spawn_worker<T: Worker + Sync + 'static>( &self, worker: T, restart_on_fork: bool, ) -> Result<WorkerHandle, SharedRuntimeError>

Spawns a worker. restart_on_fork = true causes ForkSafeRuntime::after_fork_child to reset and restart it; false drops it without calling shutdown. BasicRuntime and [LocalRuntime] ignore this flag — they do not implement a fork protocol.

async fn shutdown_async(&self)

Shuts down all tracked workers. The runtime itself is not torn down — call ForkSafeRuntime::shutdown (native only) to also drop the tokio runtime.