Struct SzRuntime 

pub struct SzRuntime { /* private fields */ }

SZ-Rust 异步运行时

对齐 PHP think-swoole 的运行时模型：基于 tokio multi_thread runtime， worker 数量默认 = CPU 核数（对齐 swoole_cpu_num()）。

设计

• 封装 tokio::runtime::Runtime，对外暴露 block_on / spawn 入口
• 持有 CancellationToken，所有后台任务通过 shutdown_token() 监听关闭信号
• shutdown_timeout 触发关闭流程：先 cancel() 通知所有任务，等待超时后 drop runtime

用法

use sz_rust_core::runtime::SzRuntime;
use std::time::Duration;

let rt = SzRuntime::new();
assert!(rt.worker_threads() > 0);

// spawn 后台任务
let handle = rt.spawn(async { 42 });
assert_eq!(rt.block_on(handle).unwrap(), 42);

// 优雅关闭
assert!(rt.shutdown_timeout(Duration::from_millis(100)));

Implementations

impl SzRuntime

pub fn new() -> Self

创建 SzRuntime，worker_threads = num_cpus::get()（对齐 swoole_cpu_num()）

pub fn with_worker_threads(worker_threads: usize) -> Self

创建 SzRuntime，自定义 worker_threads（对齐 worker_num 配置项）

• worker_threads = 0 会被强制为 1

pub fn worker_threads(&self) -> usize

获取 worker 线程数

pub fn shutdown_token(&self) -> CancellationToken

获取关闭令牌的克隆

后台任务通过 rt.shutdown_token().cancelled().await 监听关闭信号。

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

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

在 runtime 上 spawn 异步任务（对齐 swoole_event::defer）

返回 JoinHandle，可 await 获取结果。

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

where F: Future,

在 runtime 上阻塞运行 future（对齐 Swoole\Runtime::enableCoroutine 入口）

调用线程会阻塞直到 future 完成。

pub fn shutdown_timeout(self, timeout: Duration) -> bool

触发优雅关闭：cancel() 通知所有后台任务，等待 timeout 后 drop runtime

• 返回 true：runtime 已关闭
• 注意：Drop runtime 时 tokio 会等待所有任务完成，超时由调用方控制

pub fn handle(&self) -> Handle

获取内部 runtime 句柄（用于在不持有 SzRuntime 时 spawn 任务）

Trait Implementations

impl Default for SzRuntime

fn default() -> Self

Returns the “default value” for a type.