为什么在阻塞任务的循环中用`tokio::spawn`生成的任务无法执行？

你的main函数在调用spawn_blocking后立即执行完毕，触发了Tokio Runtime的关闭流程。一旦Runtime进入关闭状态，就不再允许创建新的异步任务（tokio::spawn会返回错误），因此你在阻塞线程里尝试生成的任务根本没被提交到Runtime，自然不会执行。

让main函数持续运行，确保Runtime保持活跃状态。常见的实现方式有两种：

1. 等待阻塞任务的句柄 #

由于你的阻塞任务是无限循环（监听数据包），await其返回的JoinHandle会让main函数一直等待，Runtime也会持续运行：

#[tokio::main(flavor = "multi_thread", worker_threads = 10)]
async fn main() {
    // 保存spawn_blocking的句柄
    let blocking_handle = tokio::task::spawn_blocking(move || {
        println!("Spawned blocking!");

        loop {
            println!("PRE SPAWN");
            // 添加错误处理，确认任务是否成功生成
            match tokio::spawn(async move {
                println!("Spawned INSIDE blocking!");
                // 这里添加你的数据包非阻塞处理逻辑
            }) {
                Ok(_) => {},
                Err(e) => eprintln!("Failed to spawn task: {}", e),
            }
            // 模拟等待数据包的延迟，实际代码替换为监听逻辑
            std::thread::sleep(std::time::Duration::from_millis(100));
        }
    });

    // 等待阻塞任务完成（无限循环会让main一直阻塞）
    blocking_handle.await.unwrap();
}

2. 使用信道控制并发（推荐） #

如果数据包到来速度过快，直接生成大量异步任务可能导致Runtime负载过高。可以用tokio::sync::mpsc信道限制并发处理的任务数：

#[tokio::main(flavor = "multi_thread", worker_threads = 10)]
async fn main() {
    // 创建带缓冲的信道，限制并发数
    let (sender, mut receiver) = tokio::sync::mpsc::channel(100);

    // 启动固定数量的工作任务处理数据包
    for _ in 0..10 {
        tokio::spawn(async move {
            while let Some(packet) = receiver.recv().await {
                println!("Processing packet: {:?}", packet);
                // 这里添加数据包处理逻辑
            }
        });
    }

    let blocking_handle = tokio::task::spawn_blocking(move || {
        println!("Spawned blocking!");

        loop {
            println!("PRE SPAWN");
            // 模拟获取到数据包
            let packet = "dummy_packet";
            // 发送数据包到信道，信道满时会阻塞同步线程
            if sender.blocking_send(packet).is_err() {
                eprintln!("Worker tasks exited");
                break;
            }
            std::thread::sleep(std::time::Duration::from_millis(100));
        }
    });

    blocking_handle.await.unwrap();
}

内容的提问来源于stack exchange，提问作者Rafael Costa