Rust中tokio::spawn调用自定义并发函数时Send trait证明失败问题

编译器无法证明async block满足Send trait，核心是你的join_all_discard和try_join_all_discard函数没有对传入的Future添加Send约束。tokio::spawn要求提交的任务必须是Send（因为Tokio多线程运行时会在不同线程间调度任务），而FuturesUnordered<T>实现Send的前提是T（即每个子Future）是Send，你的泛型约束缺失了这一点，导致编译器无法推导整个async block的Send性。

给两个函数的泛型约束补充Send相关限制：

修正后的join_all_discard #

use futures::{
    stream::{FuturesUnordered, StreamExt},
    Future,
};

#[derive(Debug)]
struct Foo; // 示例定义Foo，需保证Foo: Sync（因为process_foo接收&Foo）

fn main() {
    tokio::spawn(async move {
        let foos = [Foo, Foo, Foo];
        join_all_discard(foos.iter().map(|foo| process_foo(foo))).await;
    });
}

async fn process_foo(foo: &Foo) {
    // 模拟异步操作
    tokio::time::sleep(tokio::time::Duration::from_millis(100)).await;
}

async fn join_all_discard<I>(iter: I)
where
    I: IntoIterator,
    I::Item: Future<Output = ()> + Send, // 新增Send约束
{
    let mut stream: FuturesUnordered<_> = iter.into_iter().collect();
    while let Some(()) = stream.next().await {}
}

修正后的try_join_all_discard #

async fn try_join_all_discard<I, E>(iter: I) -> Result<(), E>
where
    I: IntoIterator,
    I::Item: Future<Output = Result<(), E>> + Send, // 新增Send约束
    E: Send, // 错误类型也需要Send，因为可能跨线程传递
{
    let mut stream: FuturesUnordered<_> = iter.into_iter().collect();
    loop {
        match stream.next().await {
            Some(Ok(())) => continue,
            Some(Err(e)) => break Err(e),
            None => break Ok(()),
        }
    }
}

• 如果你的Foo类型包含非Sync的内部状态（比如RefCell），那么&Foo不满足Send，此时需要改为传递Foo的所有权，或者用Arc<Foo>来共享，保证引用的线程安全性。
• futures::join_all之所以能正常工作，是因为它的泛型约束里默认包含了Send相关的隐式推导，而你手动实现的版本需要显式声明约束。

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