Rust 中如何创建线程？-JavaScript中文网-JavaScript教程资源分享门户

推荐答案

在 Rust 中，可以使用标准库中的 std::thread 模块来创建线程。以下是一个简单的示例，展示了如何创建一个线程并执行任务：

// www.javascriptcn.com code example
use std::thread;
use std::time::Duration;

fn main() {
    let handle = thread::spawn(|| {
        for i in 1..10 {
            println!("hi number {} from the spawned thread!", i);
            thread::sleep(Duration::from_millis(1));
        }
    });

    for i in 1..5 {
        println!("hi number {} from the main thread!", i);
        thread::sleep(Duration::from_millis(1));
    }

    handle.join().unwrap();
}

在这个示例中，thread::spawn 函数用于创建一个新线程，并传入一个闭包作为线程的执行体。handle.join() 用于等待线程执行完成。

本题详细解读

1. 使用 `thread::spawn` 创建线程

thread::spawn 是 Rust 标准库中用于创建线程的函数。它接受一个闭包作为参数，闭包中的代码将在新线程中执行。thread::spawn 返回一个 JoinHandle，通过这个句柄可以等待线程执行完成。

2. 线程的执行体

在 thread::spawn 中传入的闭包是线程的执行体。闭包中的代码将在新线程中并发执行。在这个示例中，闭包打印了 1 到 9 的数字，并在每次打印后休眠 1 毫秒。

3. 主线程与子线程的并发执行

在 main 函数中，主线程和子线程是并发执行的。主线程打印了 1 到 4 的数字，并在每次打印后休眠 1 毫秒。子线程则在后台打印 1 到 9 的数字。

4. 使用 `join` 等待线程完成

handle.join() 用于等待子线程执行完成。join 方法会阻塞当前线程，直到子线程执行完毕。如果子线程成功执行完成，join 返回 Ok，否则返回 Err。

5. 线程的生命周期

Rust 的线程生命周期与 JoinHandle 相关联。当 JoinHandle 被丢弃时，如果线程仍在运行，Rust 会尝试终止该线程。因此，通常建议显式调用 join 来确保线程正确执行完成。

6. 线程间的数据共享

Rust 的线程安全模型通过所有权和借用规则来确保线程间的数据共享是安全的。通常，可以使用 Arc（原子引用计数）和 Mutex（互斥锁）来在线程间安全地共享数据。

// www.javascriptcn.com code example
use std::sync::{Arc, Mutex};
use std::thread;

fn main() {
    let counter = Arc::new(Mutex::new(0));
    let mut handles = vec![];

    for _ in 0..10 {
        let counter = Arc::clone(&counter);
        let handle = thread::spawn(move || {
            let mut num = counter.lock().unwrap();
            *num += 1;
        });
        handles.push(handle);
    }

    for handle in handles {
        handle.join().unwrap();
    }

    println!("Result: {}", *counter.lock().unwrap());
}

在这个示例中，Arc 用于在多个线程间共享 Mutex 包裹的计数器，确保线程安全地修改计数器。

Rust 中如何创建线程？