#async #pi #run-time #universal #local #thread-local #mvp

nightly pi-async-rt

Based on future (MVP), a universal asynchronous runtime and tool used to provide a foundation for the outside world

16 releases

new 0.2.2 Apr 17, 2024
0.2.0 Feb 23, 2024
0.1.16 Oct 13, 2023
0.1.11 Jul 21, 2023

#47 in Asynchronous

Download history 189/week @ 2023-12-24 131/week @ 2023-12-31 51/week @ 2024-01-07 39/week @ 2024-01-14 24/week @ 2024-01-21 14/week @ 2024-01-28 36/week @ 2024-02-04 32/week @ 2024-02-11 247/week @ 2024-02-18 88/week @ 2024-02-25 71/week @ 2024-03-03 92/week @ 2024-03-10 48/week @ 2024-03-17 87/week @ 2024-03-24 115/week @ 2024-03-31 17/week @ 2024-04-07

280 downloads per month
Used in 20 crates

MIT/Apache

395KB
8K SLoC

基于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 pi_async::prelude::{MultiTaskRuntime, MultiTaskRuntimeBuilder, StealableTaskPool};
 use pi_async::rt::AsyncRuntimeExt;

 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 {});

基准测试

云服务平台

  • 16核(vCPU) 2.5 GHz主频、3.2 GHz睿频的Intel ® Xeon ® Platinum 8269CY(Cascade Lake)
  • 内存:64G
  • CentOS 7.3 64位
项目 pi_async async_std tokio 备注
bench_async_mutex 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)
no_contention 215,515 ns/iter (+/- 1,121) 225,034 ns/iter (+/- 740) 550,285 ns/iter (+/- 2,313)
await_empty_many 605,232 ns/iter (+/- 125,354) 394,823 ns/iter (+/- 19,107) 393,625 ns/iter (+/- 4,459)
chained_spawn 504,570 ns/iter (+/- 24,166) 1,090,176 ns/iter (+/- 27,817) 251,943 ns/iter (+/- 1,412)
ping_pong 1,176,361 ns/iter (+/- 197,786) 3,859,845 ns/iter (+/- 73,410) 1,193,711 ns/iter (+/- 20,376)
spawn_empty_many 4,187,949 ns/iter (+/- 587,053) 18,887,015 ns/iter (+/- 347,589) 9,941,412 ns/iter (+/- 659,722)
spawn_many 3,436,761 ns/iter (+/- 279,137) 19,001,495 ns/iter (+/- 380,355) 7,615,952 ns/iter (+/- 210,639)
spawn_one_to_one 6,205,756 ns/iter (+/- 826,745) 36,189,628 ns/iter (+/- 357,690) 16,620,075 ns/iter (+/- 589,085)
yield_many 23,757,528 ns/iter (+/- 4,110,213) 52,304,694 ns/iter (+/- 519,928) 17,746,497 ns/iter (+/- 550,878)
block_on 83 ns/iter (+/- 0) 2,593 ns/iter (+/- 48) 178 ns/iter (+/- 1)
local_run 666,627 ns/iter (+/- 5,476)
local_send_many 5,885,537 ns/iter (+/- 98,251)
local_spawn_many 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.

Dependencies

~6–37MB
~535K SLoC