如何在Rust作用域线程中共享布尔标志？

尝试用布尔标志通知线程退出时，代码违反了Rust的借用检查规则，原代码如下：

fn long_running(exit_flag: &bool) {
    loop {
        std::thread::sleep(std::time::Duration::from_secs(10));
        if *exit_flag {
            break;
        }
    }
}

fn main() {
    let mut exit_flag = false;
    std::thread::scope(|scope| {
        let handle = scope.spawn(|| {
            long_running(&exit_flag); // (1)
        });

        exit_flag = true; // (2)

        handle.join().expect("failed to join thread");
    });
}

问题分析 #

标记为(1)和(2)的行违反了Rust核心借用规则：

• (1)处对exit_flag发起不可变借用，并传递给子线程，此时该引用在子线程生命周期内持续有效
• (2)处尝试在不可变借用仍存在时修改exit_flag，违反了"同一时间只能存在一个可变引用，或多个不可变引用"的排他性规则

修复方案 #

最适配需求的方案是使用原子布尔类型AtomicBool，它支持线程安全的读写操作，且可以直接存储在父线程栈上，完全符合std::thread::scope访问栈变量的设计初衷，无需额外堆分配。

修改后的代码如下：

use std::sync::atomic::{AtomicBool, Ordering};

fn long_running(exit_flag: &AtomicBool) {
    loop {
        std::thread::sleep(std::time::Duration::from_secs(10));
        // Acquire顺序保证读取到最新的标志值
        if exit_flag.load(Ordering::Acquire) {
            break;
        }
    }
}

fn main() {
    // 栈上创建原子布尔标志，初始值为false
    let exit_flag = AtomicBool::new(false);
    std::thread::scope(|scope| {
        let handle = scope.spawn(|| {
            long_running(&exit_flag);
        });

        // Release顺序保证写入的标志值对其他线程可见
        exit_flag.store(true, Ordering::Release);

        handle.join().expect("failed to join thread");
    });
}

方案说明

• AtomicBool通过硬件级原子操作实现线程安全，无需手动管理引用生命周期
• 内存顺序Ordering::Acquire和Ordering::Release确保主线程的写入操作能被子线程及时感知，避免指令重排导致的同步问题
• 变量始终存储在父线程栈上，完全契合thread::scope的使用场景，没有额外的内存分配开销

其他可选方案 #

如果后续需要扩展更复杂的线程间同步逻辑，可以使用Mutex<bool>包裹布尔值，但对于简单的退出标志场景，AtomicBool是更轻量、高效的选择：

use std::sync::Mutex;

fn long_running(exit_flag: &Mutex<bool>) {
    loop {
        std::thread::sleep(std::time::Duration::from_secs(10));
        if *exit_flag.lock().unwrap() {
            break;
        }
    }
}

fn main() {
    let exit_flag = Mutex::new(false);
    std::thread::scope(|scope| {
        let handle = scope.spawn(|| {
            long_running(&exit_flag);
        });

        *exit_flag.lock().unwrap() = true;

        handle.join().expect("failed to join thread");
    });
}

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