基于Future(MVP)，用于为外部提供基础的通用异步运行时和工具

主要特征

• 任务池: 可定制的任务池
• 任务ID: 外部使用任务ID可以很方便的唤醒和挂起
• 抽象接口: 可以自由实现自己的运行时
• 运行时推动：单线程运行时可以用自己的方式推动运行

Examples

本地异步运行时:

 use pi_async_rt::rt::{AsyncRuntime, AsyncRuntimeExt, serial_local_thread::{LocalTaskRunner, LocalTaskRuntime}};
 let rt = LocalTaskRunner::<()>::new().into_local();
 let _ = rt.block_on(async move {});

多线程异步运行时使用:

 use pi_async_rt::rt::{AsyncRuntime, AsyncRuntimeExt};
 use pi_async_rt::rt::multi_thread::{MultiTaskRuntime, MultiTaskRuntimeBuilder, StealableTaskPool};

 let pool = StealableTaskPool::with(4,100000,[1, 254],3000);
 let builer = MultiTaskRuntimeBuilder::new(pool)
     .set_timer_interval(1)
     .init_worker_size(4)
     .set_worker_limit(4, 4);
 let rt = builer.build();
 let _ = rt.spawn(async move {});

timeout 等待句柄

runtime.timeout(ms).await 使用 timeout 专用等待句柄，不再为每次 timeout 分配普通任务 TaskId/TaskHandle。该实现保持公开 API 不变，并保留当前 timer 不支持取消的语义：

• timeout 到期后唤醒等待任务，并在 future 完成后释放等待句柄。
• timeout future 被提前 drop 时会清理 waker，timer 到期后释放内部等待句柄。
• 不修改普通 spawn、spawn_timing、任务池和 worker loop 的核心语义。
• 内部等待状态使用原子到期标记和 AtomicWaker，不引入自旋等待或阻塞锁。

建议验证命令：

cargo test --lib timeout_waiter_tests
cargo test --test timeout_waiter
cargo test --test timeout_waiter test_multi_thread_timeout_churn_rss_diagnostic -- --ignored --nocapture
cargo test --features serial --test timeout_waiter
cargo bench --bench timeout_waiter_pi_async -- --nocapture

AsyncValue

AsyncValue<V> 是同步非阻塞、只允许设置一次的 single-shot future。当前实现保持公开 API 不变：

• AsyncValue::new()、AsyncValue::set(self, value) 和 Future<Output = V> 签名不变。
• set() 保持旧语义：第一次设置成功，后续设置静默失败且不会覆盖已设置值。
• pending 后允许重复 poll，重复 poll 会更新最新 waker，不会 panic。
• set 后唤醒最新 waker；never set 的 future 会继续 pending。
• 当前 API 不表达 sender/receiver 拆分、关闭或取消语义。

建议验证命令：

cargo test --test async_value -- --nocapture --test-threads=1
cargo test --features serial --test async_value -- --nocapture --test-threads=1
cargo bench --bench async_value_pi_async -- --nocapture
cargo bench --features serial --bench async_value_pi_async -- --nocapture

本地专项基准样例（WSL2 Ubuntu 22.04）：

worker wake/sleep 唤醒协议

多线程 runtime 的 worker 空闲休眠路径会在任务入队或任务 waker 被外部线程触发后即时唤醒 sleeping worker，不再依赖 worker_sleep_timeout 超时兜底。该修复保持公开 API 不变：

• 不修改 AsyncRuntime trait。
• 不修改 spawn、spawn_local、timeout、yield_now 的函数签名和返回语义。
• 每次入队或 wake 最多唤醒一个 worker，避免广播式唤醒风暴。
• worker 休眠注册和外部唤醒使用同一个 condvar predicate，避免 “任务已入队但 worker 继续睡到 timeout” 的 lost wake。
• waits 队列使用有限扫描和 stale entry 清理，不进行无界循环。
• direct worker thread 和 serial worker thread 同步使用二次检查协议。
• AsyncRuntimeBuilder::default_multi_thread(..., Some(0), ...) 保持原有 builder fallback 语义，不会构建 0 worker pool；Some(n > 0) 仍创建同尺寸 StealableTaskPool，避免 worker 数大于 pool slot。

建议验证命令：

cargo test --lib worker_waker -- --nocapture --test-threads=1
cargo test --test worker_wakeup -- --nocapture --test-threads=1
cargo test --features serial --lib worker_waker -- --nocapture --test-threads=1
cargo bench --bench worker_wakeup_pi_async -- --nocapture

本地专项基准样例（WSL2 Ubuntu 22.04，8 worker）：

• AsyncValue 外部 wake：p50 66.705us，p99 137.103us，max 169.398us。
• 外部 spawn：p50 65.402us，p99 153.818us，max 213.274us。
• 8 个外部 producer 并发 spawn 到 8 worker runtime，1,000,000 个空任务：约 7,139,442 tasks/sec。
• 百万并发空任务资源观测：最大 RSS 80,236 KiB，Swaps 0。

基准测试

云服务平台

• 16核(vCPU) 2.5 GHz主频、3.2 GHz睿频的Intel ® Xeon ® Platinum 8269CY（Cascade Lake）
• 内存:64G
• CentOS 7.3 64位

贡献指南

License

This project is licensed under the MIT license.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in pi_async by you, shall be licensed as MIT, without any additional terms or conditions.