将线程的迭代器收集到向量中启动线程

Question

下面的 sn-p 显示了将迭代器映射到线程并收集到 Vec

let workers = input
        .chunks(chunk_size)
        .map(|chunk| {
            let lines = chunk.iter().map(|s| s.to_string()).collect::<Vec<_>>();
            thread::spawn(move || count_letters(&lines))
        })
        .collect::<Vec<_>>(); 

这不会启动所有线程运行（直到创建它们的操作系统）？换句话说，除了input的长度之外，将创建多少个线程并没有真正的限制。

假设这是真的，如果想要在不实例化collect 上的所有线程的情况下执行此模式，可能会使用另一种闭包，即thread::spawn(move || count_letters(&lines)) -> || thread::spawn(move || count_letters(&lines))，这会是 rust 风格吗？

Answer 1

这不会启动所有线程运行（直到创建它们的操作系统）？

是的。从技术上讲，这里甚至不需要collect，for 就可以了。

假设这是真的，如果一个人想在不实例化所有线程的情况下执行这种模式，可能会使用另一个闭包

但是……为什么要打扰spawn，或者两个闭包？你可以把它放在你要调用外部闭包的地方。

这会是 rust 风格吗？

rust 样式可能会使用rayon。

如果您想手动执行此操作，那么通常：创建一个队列（某种 mpmc 通道，可能是有界的），从队列中生成多少工作人员，将所有工作推送到队列中，然后以某种方式收集结果。