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

主要特征

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

Examples

本地异步运行时: use pi_async::rt::{AsyncRuntime, AsyncRuntimeExt, serial_local_thread::{LocalTaskRunner, LocalTaskRuntime}}; let rt = LocalTaskRunner::<()>::new().into_local(); let _ = rt.block_on(async move {});

多线程异步运行时使用: ``` use piasync::prelude::{MultiTaskRuntime, MultiTaskRuntimeBuilder, StealableTaskPool}; use piasync::rt::AsyncRuntimeExt;

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

基准测试

云服务平台

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

|项目|piasync|asyncstd|tokio|备注| |---|---|---|---|---| |benchasyncmutex|3,266 ns/iter (+/- 136)|149,332 ns/iter (+/- 7,212)|6,374,238 ns/iter (+/- 861,432)|| |contention|338,786 ns/iter (+/- 68,222)|901,779 ns/iter (+/- 28,380)|2,157,495 ns/iter (+/- 38,100)|| |create|257 ns/iter (+/- 2)|61 ns/iter (+/- 0)|63 ns/iter (+/- 0)|| |nocontention|215,515 ns/iter (+/- 1,121)|225,034 ns/iter (+/- 740)|550,285 ns/iter (+/- 2,313)|| |awaitemptymany|605,232 ns/iter (+/- 125,354)|394,823 ns/iter (+/- 19,107)|393,625 ns/iter (+/- 4,459)|| |chainedspawn|504,570 ns/iter (+/- 24,166)|1,090,176 ns/iter (+/- 27,817)|251,943 ns/iter (+/- 1,412)|| |pingpong|1,176,361 ns/iter (+/- 197,786)|3,859,845 ns/iter (+/- 73,410)|1,193,711 ns/iter (+/- 20,376)|| |spawnemptymany|4,187,949 ns/iter (+/- 587,053)|18,887,015 ns/iter (+/- 347,589)|9,941,412 ns/iter (+/- 659,722)|| |spawnmany|3,436,761 ns/iter (+/- 279,137)|19,001,495 ns/iter (+/- 380,355)|7,615,952 ns/iter (+/- 210,639)|| |spawnonetoone|6,205,756 ns/iter (+/- 826,745)|36,189,628 ns/iter (+/- 357,690)|16,620,075 ns/iter (+/- 589,085)|| |yieldmany|23,757,528 ns/iter (+/- 4,110,213)|52,304,694 ns/iter (+/- 519,928)|17,746,497 ns/iter (+/- 550,878)|| |blockon|83 ns/iter (+/- 0)|2,593 ns/iter (+/- 48)|178 ns/iter (+/- 1)|| |localrun|666,627 ns/iter (+/- 5,476)|||| |localsendmany|5,885,537 ns/iter (+/- 98,251)|||| |localspawnmany|1,260,102 ns/iter (+/- 5,423)|20,201,034 ns/iter (+/- 692,642)|1,553,246 ns/iter (+/- 49,815)||

贡献指南

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.