Struct SharedRuntime 

pub struct SharedRuntime(/* private fields */);

Shared tokio runtime for all network subsystems.

Created once at server startup and passed to all subsystems via cloning. This ensures efficient work-stealing across HTTP, WebSocket, and admin servers.

Example

let runtime = SharedRuntime::new(num_cpus::get());

// Pass cloned runtime to subsystems
let http = HttpSubsystem::new(addr, state, runtime.clone());
let ws = WsSubsystem::new(addr, state, runtime.clone());

Implementations

impl SharedRuntime

pub fn new(worker_threads: usize) -> Self

Create a new shared runtime with the specified number of worker threads.

Arguments

• worker_threads - Number of tokio worker threads. Typically num_cpus::get().

Panics

Panics if the tokio runtime cannot be created.

pub fn handle(&self) -> Handle

Get a handle for spawning tasks on this runtime.

The handle can be cloned and passed to multiple subsystems. Tasks spawned via the handle run on the shared runtime’s thread pool.

pub fn block_on<F: Future>(&self, future: F) -> F::Output

Block the current thread until the future completes.

Used during server startup/shutdown from synchronous context. Should not be called from within an async context.

pub fn spawn<F>(&self, future: F) -> JoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

Spawn a future on this runtime.

Returns a JoinHandle that can be used to await the result.

Trait Implementations

impl Clone for SharedRuntime

fn clone(&self) -> SharedRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for SharedRuntime

fn default() -> Self

Returns the “default value” for a type.