Rust中满足条件终止线程 并发搜索两个HashMap键的实现方案

你的代码虽然能运行，但存在两个核心缺陷：

• 逻辑上无法做到立即终止：你把遍历键和接收通道消息分成了两个独立的串行循环，只有当线程遍历完自己负责的所有HashMap键之后，才会去读取通道消息。如果另一个线程在遍历过程中就找到了目标值，当前线程必须等自己遍历完全部键才能收到终止信号，完全达不到“找到即终止”的要求。
• 通道使用冗余：你为每个线程单独建了一组收发通道，虽然每个mpsc通道实际是单生产者单消费者的用法，不算违反mpsc的设计，但整个结构完全没有必要，维护成本高且性能不如更轻量的同步原语。

推荐使用Arc<AtomicBool>作为全局终止标记，这是成本最低、响应最快的实现方式：原子变量的读取是无锁操作，不会给遍历过程增加明显负担，且可以做到每次迭代都检查终止状态，实现真正的立即终止。
示例实现如下：

use std::collections::HashMap;
use std::array::IntoIter;
use std::thread;
use std::iter::FromIterator;
use std::sync::Arc;
use std::sync::atomic::{AtomicBool, Ordering};

fn main() {
    let m1 = HashMap::<_, _>::from_iter(IntoIter::new([(1, 2), (3, 4), (5, 6), (7,8), (9, 10)]));
    let m2 = HashMap::<_, _>::from_iter(IntoIter::new([(1, 2), (3, 4), (5, 6), (7,8), (9, 10), (11, 12), (13, 14), (15, 16), (17,18), (19, 20)]));
    const TARGET: u8 = 11;

    // 全局终止标记，找到目标值后设为true
    let found = Arc::new(AtomicBool::new(false));

    let found_clone1 = found.clone();
    let handle1 = thread::spawn(move || {
        for k in m1.keys() {
            // 每次迭代先检查是否已经被其他线程找到
            if found_clone1.load(Ordering::Relaxed) {
                break;
            }
            if *k == TARGET {
                found_clone1.store(true, Ordering::Relaxed);
                println!("handle1 found target: {k}");
                break;
            }
            println!("Key from handle1: {k}");
        }
        m1
    });

    let found_clone2 = found.clone();
    let handle2 = thread::spawn(move || {
        for k in m2.keys() {
            if found_clone2.load(Ordering::Relaxed) {
                break;
            }
            if *k == TARGET {
                found_clone2.store(true, Ordering::Relaxed);
                println!("handle2 found target: {k}");
                break;
            }
            println!("Key from handle2: {k}");
        }
        m2
    });

    handle1.join().unwrap();
    handle2.join().unwrap();
}

你代码中的thread::sleep没有任何实际业务意义，仅为了在小样本测试时模拟耗时操作，强制让出CPU时间片给另一个线程调度，方便观察并发效果。
你注释掉sleep后出现顺序执行的现象，是因为测试用的HashMap容量极小，遍历全程耗时远小于操作系统的线程调度时间片，第一个线程启动后会在时间片用完前就完成全部遍历，第二个线程才会被调度执行，所以看起来是串行的。如果是生产环境下的大体积HashMap，不需要加sleep也会出现自然的线程调度切换。

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