Struct Runtime 

pub struct Runtime { /* private fields */ }

A configured Asupersync runtime.

Created via RuntimeBuilder. The runtime owns worker threads and a three-lane priority scheduler. Clone is cheap (shared Arc).

Example

let runtime = RuntimeBuilder::new().worker_threads(2).build()?;

// Run a future to completion on the current thread.
let result = runtime.block_on(async { 1 + 1 });
assert_eq!(result, 2);

// Spawn from outside async context via a handle.
let handle = runtime.handle().spawn(async { 42u32 });
let value = runtime.block_on(handle);
assert_eq!(value, 42);

Implementations

impl Runtime

pub fn with_config(config: RuntimeConfig) -> Result<Self, Error>

Construct a runtime from the given configuration.

pub fn with_config_and_reactor( config: RuntimeConfig, reactor: Option<Arc<dyn Reactor>>, ) -> Result<Self, Error>

Construct a runtime from the given configuration and reactor.

pub fn handle(&self) -> RuntimeHandle

Returns a handle that can spawn tasks from outside the runtime.

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

Run a future to completion on the current thread.

pub fn config(&self) -> &RuntimeConfig

Returns a reference to the runtime configuration.

pub fn is_quiescent(&self) -> bool

Returns true if the runtime is quiescent (no live tasks or I/O).

pub fn spawn_blocking<F>(&self, f: F) -> Option<BlockingTaskHandle>

where F: FnOnce() + Send + 'static,

Spawns a blocking task on the blocking pool.

Returns None if the blocking pool is not configured (max_threads = 0).

Example

let runtime = RuntimeBuilder::new()
    .blocking_threads(1, 4)
    .build()?;

let handle = runtime.spawn_blocking(|| {
    std::fs::read_to_string("/etc/hosts")
});

pub fn blocking_handle(&self) -> Option<BlockingPoolHandle>

Returns a handle to the blocking pool, if configured.

Trait Implementations

impl Clone for Runtime

fn clone(&self) -> Runtime

Returns a duplicate of the value.

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

Performs copy-assignment from source.