async-task-group

致谢

此代码库基于 Pat Hickey 的 task-group 项目。

示例

创建一个回显 TCP 服务器，该服务器在循环中处理传入连接，而不会创建任何悬空任务

use async_std::io;
use async_std::net::{TcpListener, TcpStream};
use async_std::prelude::*;
use async_std::task;

async fn process(stream: TcpStream) -> io::Result<()> {
    println!("Accepted from: {}", stream.peer_addr()?);

    let mut reader = stream.clone();
    let mut writer = stream;
    io::copy(&mut reader, &mut writer).await?;

    Ok(())
}

#[async_std::main]
async fn main() -> io::Result<()> {
    let listener = TcpListener::bind("127.0.0.1:8080").await?;
    println!("Listening on {}", listener.local_addr()?);

    let handle = async_task_group::group(|group| async move {
        let mut incoming = listener.incoming();
        while let Some(stream) = incoming.next().await {
            let stream = stream?;
            group.spawn(async move { process(stream).await });
        }
        Ok(group)
    });
    handle.await?;
    Ok(())
}

安装

$ cargo add async-task-group

安全性

此 crate 使用 #![deny(unsafe_code)] 确保所有内容都在 100% 安全的 Rust 中实现。

贡献

想要加入我们吗？查看我们的 "贡献" 指南 并查看一些这些问题

• 标记为 "good first issue" 的问题
• 标记为 "help wanted" 的问题

许可证