Uringy

Rust 中编写并发代码不必痛苦。Uringy 是一个运行时，它结合了结构化并发、单线程设计和 Linux 的 io_uring。适用于服务器应用程序，从简单的单线程到高度可扩展的线程每核心设计。

目标

简单的 API

• 熟悉的阻塞语法，与 Rust 的标准库紧密对应
• 避免 async/await 的限制和陷阱
• 具有出色的文档和示例，易于学习
• 使用非 Send 和非 'static 类型启动
• 具有一流取消支持的纤维层次结构，无泄漏

性能优良

• 使用 io_uring 发送非阻塞、批量、零拷贝系统调用
• 使用协作多任务进行高效上下文切换
• 无原子调度器，如有需要可手动并行化

编译速度快

• 使用 [cargo 特性](#编译时间标志) 仅编译所需内容
• 依赖性最小化
• 宏使用最少

快速入门

安装 Rust 并 创建新的 cargo 项目。

将 uringy 添加为依赖项：cargo add uringy

然后替换 src/main.rs 为

// No need for async main
#[uringy::start]
fn main() {
    let handle = uringy::fiber::spawn(|| tcp_echo_server(9000)); // No need for async block

    uringy::signals().filter(Signal::is_terminal).next().unwrap();
    uringy::println!("gracefully shutting down");
    handle.cancel(); // Cancellation propagates throughout the entire fiber hierarchy

    // Automatically waits for all fibers to complete
}

// No need for async functions
fn tcp_echo_server(port: u16) {
    let listener = uringy::net::TcpListener::bind(("0.0.0.0", port)).unwrap();
    uringy::println!("listening for TCP connections on port {port}"); // No need for .await
    let mut connections = listener.incoming();
    while let Ok((stream, _)) = connections.next() {
        uringy::fiber::spawn(move || handle_connection(stream));
    }
}

fn handle_connection(tcp: TcpStream) {
    let (mut r, mut w) = stream.split();
    let _ = std::io::copy(&mut r, &mut w); // TcpStream implements std::io's Read and Write
}

然后使用：cargo run --release 运行您的项目

如果您使用的是 macOS，请使用一个 Linux 虚拟机 或 docker 容器。如果您使用的是 Windows，请使用 WSL。

有关更多信息，请查看 示例目录。

编译时间标志

目前没有 cargo 标志。

与其他运行时的比较

支持的Rust版本

MSRV是1.70.0（于2023年6月发布）。请在终端中运行rustc --version来检查您的Rust版本。

支持的Linux内核版本

最低内核版本是6.1（于2022年12月发布）。请在终端中运行uname -r来检查您的内核版本。

许可

Uringy遵循MIT许可。这是一个宽容的许可，基本上意味着你可以做任何你想做的事情。