Function std::thread::spawn

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

产生一个新线程，为其返回 JoinHandle。

连接句柄提供了一个 join 方法，可用于连接新建线程。如果新建线程 panics，join 将返回一个 Err，其中包含给 panic! 的参数。

如果连接句柄是删除，则新建线程将隐式地分离。 在这种情况下，可能不再加入新建线程。 (最终加入它创建的线程或分离它们是程序的责任; 否则，将导致资源泄漏。)

此调用将使用 Builder 的默认参数创建线程，如果要指定栈大小或线程名称，请改用此 API。

如您在 spawn 的签名中所见，给 spawn 的闭包及其返回值都有两个约束，让我们对其进行解释：

• 'static 约束意味着闭包及其返回值必须具有整个程序执行的生命周期。这样做的原因是线程可以比创建它们的生命周期更长。

  确实，如果线程及其扩展值可以超过调用者的生命周期，我们需要确保它们之后才有效，并且由于我们 无法 知道何时返回，因此需要使它们有效尽可能直到程序结束，因此是 'static 生命周期。

• Send 约束是因为闭包将需要从产生它的线程中传递 by value 到新线程。它的返回值需要从新线程传递到 join 线程。 提醒一下，Send 标记 trait 表示从线程传递到线程是安全的。Sync 表示在每个线程之间传递引用是安全的。

Panics

如果操作系统无法创建线程，就会出现 panics。使用 Builder::spawn 从此类错误中恢复。

Examples

创建一个线程。

use std::thread;

let handler = thread::spawn(|| {
    // 线程代码
});

handler.join().unwrap();

如模块文档中所述，线程通常是使用 channels 进行通信的，这是它通常的外观。

此示例还显示了如何使用 move，以便将值的所有权授予线程。

use std::thread;
use std::sync::mpsc::channel;

let (tx, rx) = channel();

let sender = thread::spawn(move || {
    tx.send("Hello, thread".to_owned())
        .expect("Unable to send on channel");
});

let receiver = thread::spawn(move || {
    let value = rx.recv().expect("Unable to receive from channel");
    println!("{}", value);
});

sender.join().expect("The sender thread has panicked");
receiver.join().expect("The receiver thread has panicked");

线程也可以通过其 JoinHandle 返回一个值，您可以使用它进行异步计算 (不过 futures 可能更合适)。

use std::thread;

let computation = thread::spawn(|| {
    // 一些昂贵的计算。
    42
});

let result = computation.join().unwrap();
println!("{}", result);