如何定义闭包类型以发送到线程安全

Question

我正在尝试将闭包发送到线程中以进行如下处理：

fn spawn<F>(work_load: F) where F: FnMut() {
    let builder = Builder::new();
    let handler = builder.spawn(move || {
        // Before process
        work_load();
        // After process
    }).unwrap();
}

但我收到一个错误： F 无法在线程之间安全发送

概括地说，我需要这样做（代码编译）：

let closure = || env_variable.to_string();

thread::spawn(move || {
    // before closure
    closure();
    // after closure
});

考虑到我需要捕获环境，我如何定义 F 以便将其发送到线程中。

Answer 1

如果您查看thread::spawn 或thread::Builder::spawn，您会看到它有签名

pub fn spawn<F, T>(f: F) -> JoinHandle<T> 
where
    F: FnOnce() -> T,
    F: Send + 'static,
    T: Send + 'static, 

这意味着线程闭包f 及其返回值都必须实现Send 特征（即可跨线程发送）并具有'static 生命周期（即没有任何非静态生命周期的借用） )。

如果所有捕获的变量都是，则闭包将为Send。如果所有捕获的变量都在并且所有捕获的变量都被移动到闭包中（这就是 move 关键字的作用），它也将是 'static。

由于闭包中唯一捕获的变量是work_load，因此您需要确保work_load 既是Send 又是'static：

fn spawn<F>(work_load: F)
where
    F: FnMut() + Send + 'static
//               ^---.---^
//                   \_ add these constraints to F