crossbeam-spawn.zh.md

生成一个短命的线程

[![crossbeam-badge]][crossbeam] [![cat-concurrency-badge]][cat-concurrency]

该示例使用了[crossbeam]箱子，为并发和并行编程，提供数据结构和函数。Scope::spawn生成一个新的作用域线程，保证crossbeam::scope函数的闭包(参数)返回之前终止，意味着，您可以从调用的函数中，引用数据。

此示例将数组拆分为一半，并在单独的线程中，执行工作。

extern crate crossbeam;

fn main() {
    let arr = &[1, 25, -4, 10];
    let max = find_max(arr);
    assert_eq!(max, Some(25));
}

fn find_max(arr: &[i32]) -> Option<i32> {
    const THRESHOLD: usize = 2;

    if arr.len() <= THRESHOLD {
        return arr.iter().cloned().max();
    }

    let mid = arr.len()/2;
    let (left, right) = arr.split_at(mid);

    crossbeam::scope(|s| {
        let thread_l = s.spawn(|_| find_max(left));
        let thread_r = s.spawn(|_| find_max(right));

        let min_l = thread_l.join().unwrap()?;
        let min_r = thread_r.join().unwrap()?;

        Some(min_l.max(min_r))
    }).unwrap()
}