Struct BasicRuntime 

pub struct BasicRuntime { /* private fields */ }

Non-fork-safe SharedRuntime implementation.

The internal Arc<tokio::runtime::Runtime> is either library-built (BasicRuntime::new / BasicRuntime::with_worker_threads) or caller-provided (BasicRuntime::from_handle). The Arc keeps the runtime alive for the lifetime of this struct even if the caller drops their clone of the handle.

This type does not implement the fork protocol. If the process forks, use crate::ForkSafeRuntime instead — or handle the fork at the outer runtime layer that owns the tokio runtime passed in.

Implementations

impl BasicRuntime

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

Creates a new BasicRuntime backed by a library-built multi-thread tokio runtime with the given number of worker threads.

pub fn from_handle(runtime: Arc<Runtime>) -> Self

Creates a new BasicRuntime wrapping a caller-provided runtime.

The runtime is held via Arc, so it stays alive for the lifetime of this struct even if the caller drops their clone.

Trait Implementations

impl BlockingRuntime for BasicRuntime

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

Drives f to completion, blocking the current thread.

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 BasicRuntime

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

Formats the value using the given formatter.

impl SharedRuntime for BasicRuntime

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.