#run-time #io #async #thread-per-core #multi-threading #io-uring #compio

compio-dispatcher

Compio 的多线程调度器

4 个版本 (2 个破坏性更新)

0.3.0 2024年6月17日
0.2.0 2024年4月25日
0.1.0 2024年3月4日
0.1.0-beta.12023年11月17日

#1873 in 异步

Download history 90/week @ 2024-04-26 31/week @ 2024-05-03 3/week @ 2024-05-10 4/week @ 2024-05-17 1/week @ 2024-05-24 3/week @ 2024-05-31 3/week @ 2024-06-07 329/week @ 2024-06-14 446/week @ 2024-06-21 461/week @ 2024-06-28 448/week @ 2024-07-05 428/week @ 2024-07-12 257/week @ 2024-07-19 374/week @ 2024-07-26 342/week @ 2024-08-02 479/week @ 2024-08-09

每月1,502次下载
用于 2 个 crate (通过 compio)

MIT 协议

275KB
6.5K SLoC

Compio

MIT licensed crates.io docs.rs Check Test Telegram

一个基于 IOCP/io_uring/polling 的每个核心一个线程的 Rust 运行时。这个名字来源于 "基于完成的 IO"。这个 crate 受 monoio 的启发。

为什么不选择 Tokio?

Tokio 是一个优秀的通用异步运行时。然而,它是基于 poll 的,甚至在 Windows 上使用了 未记录的 API。我们希望有一些新的高级 API 来执行 IOCP/io_uring。

tokio-uring 不同,这个运行时不基于 Tokio。这主要是因为在 mio 中没有公开 API 来控制 IOCP,并且 tokiomio 达到 1.0 之前不会公开 API 来控制 mio

为什么不选择 monoio/tokio-uring/glommio?

它们不支持 Windows。

快速入门

compio 添加为依赖项

compio = { version = "0.10.0", features = ["macros"] }

然后我们可以使用高级 API 来执行文件系统和网络 IO。

use compio::{fs::File, io::AsyncReadAtExt};

#[compio::main]
async fn main() {
    let file = File::open("Cargo.toml").await.unwrap();
    let (read, buffer) = file.read_to_end_at(Vec::with_capacity(1024), 0).await.unwrap();
    assert_eq!(read, buffer.len());
    let buffer = String::from_utf8(buffer).unwrap();
    println!("{}", buffer);
}

您还可以手动控制低级驱动程序。请参阅仓库中的 driver 示例。

贡献

在 Compio 的任何级别都有贡献的机会。无论您是刚开始接触 Rust 还是经验丰富的专家,我们都可以利用您的帮助。如果您对 Compio 有任何疑问,欢迎加入我们的 Telegram 群组。在贡献之前,请查看我们的 贡献指南

依赖项

~2–11MB
~118K SLoC