Rayon

Rayon 是一个 Rust 的数据并行库。它非常轻量级，能够轻松地将顺序计算转换为并行计算。它还保证了无数据竞争。（您可能还会对这篇关于 Rayon 的博客文章感兴趣，其中提供了更多背景信息和工作原理的详细说明，或者观看这个来自 Rust Belt Rust 会议的视频。）Rayon 可在 crates.io 上获取，API 文档可在 docs.rs 上查阅。

并行迭代器及更多

Rayon 使得将顺序迭代器转换为并行迭代器变得极其简单：通常，您只需将 foo.iter() 调用改为 foo.par_iter()，Rayon 就会处理剩下的事情：

use rayon::prelude::*;
fn sum_of_squares(input: &[i32]) -> i32 {
    input.par_iter() // <-- 只需更改这里！
         .map(|&i| i * i)
         .sum()
}

并行迭代器会负责决定如何将数据划分为任务；它会动态调整以达到最佳性能。如果您需要更多灵活性，Rayon 还提供了 join 和 scope 函数，让您可以自行创建并行任务。如果需要更多控制，您可以创建自定义线程池，而不是使用 Rayon 的默认全局线程池。

无数据竞争

您可能听说过并行执行可能会产生各种奇怪的 bug。不过，请放心。Rayon 的 API 都保证无数据竞争，这通常可以排除大多数并行 bug（尽管不是全部）。换句话说，如果您的代码能够编译，它通常会与之前的行为相同。

大多数情况下，并行迭代器保证会产生与其顺序对应项相同的结果。有一点需要注意：如果您的迭代器有副作用（例如，通过 Rust 通道向其他线程发送消息或写入磁盘），这些副作用可能会以不同的顺序发生。还要注意，在某些情况下，并行迭代器提供了顺序迭代器方法的替代版本，这些版本可能具有更高的性能。

使用 Rayon

Rayon 可在 crates.io 上获取。推荐的使用方法是在 Cargo.toml 中添加如下行：

[dependencies]
rayon = "1.10"

要使用并行迭代器 API，需要将多个 trait 引入作用域。最简单的方法是使用 Rayon prelude。在每个需要使用并行迭代器 API 的模块中，只需添加：

use rayon::prelude::*;

Rayon 目前需要 rustc 1.63.0 或更高版本。

在 WebAssembly 中使用

默认情况下，当构建为 WebAssembly 时，Rayon 会将其视为任何其他不支持多线程的平台，并回退到顺序迭代。这允许现有代码无需更改即可成功编译和运行，但它会运行得更慢，因为只会使用单个 CPU 核心。

您可以为 Web 构建具有适当多线程支持的基于 Rayon 的项目，但您需要一个适配器和一些项目配置来处理 WebAssembly 线程和其他平台上的线程之间的差异。

查看 wasm-bindgen-rayon 文档以获取更多详细信息。

贡献

Rayon 是一个开源项目！如果您想为 Rayon 做出贡献，请查看标记为"help wanted"的问题列表。这些都是（或应该是）适合入门的问题，它们通常包含了详细的说明。如果有任何不清楚的地方，请随时提问！此外，请查看 wiki 上的开发指南页面。请注意，所有通过 PR 提交给 Rayon 的代码都被假定为根据 Rayon 的双重 MIT/Apache 2.0 许可进行许可。

快速演示

要查看 Rayon 的实际效果，请查看 rayon-demo 目录，其中包含了多个使用 Rayon 的代码演示。例如，运行以下命令可以获得 N 体模拟的可视化效果。要查看使用 Rayon 的效果，按 s 键进行顺序运行，按 p 键进行并行运行。

> cd rayon-demo
> cargo run --release -- nbody visualize

要获取有关演示的更多信息，请尝试：

> cd rayon-demo
> cargo run --release -- --help

其他问题？

请参阅 Rayon FAQ。

许可证

Rayon 根据 MIT 许可证和 Apache 许可证（版本 2.0）的条款分发。有关详细信息，请参阅 LICENSE-APACHE 和 LICENSE-MIT。打开拉取请求被视为同意这些许可条款。