rust - Rayon 如何防止在线程之间使用 RefCell、Cell 和 Rc？

Question

Rayon 文档说它保证使用 Rayon API 不会引入数据竞争。

编译器如何知道闭包调用的方法不共享可变状态，例如 RefCell<T>和 Cell<T> ，或使用非线程安全的结构，例如 Rc<T> ？

我明白 core::marker::Sync标记可以在线程之间安全共享的类型，但我不明白 Rayon 类型声明和编译器如何强制执行它!

Answer 1

您实际上自己回答了您的问题——所有需要在线程之间共享的闭包都需要Sync，而 Rayon 的 API 只需要它们通过 trait bounds Sync .参见例如 documentation of ParallelIterator::map() , 指定方法为

fn map<F, R>(self, map_op: F) -> Map<Self, F> where
    F: Fn(Self::Item) -> R + Sync + Send,
    R: Send, 

这里没有任何更深层次的魔法——每当 Rayon 以需要它是 Sync 的方式使用闭包时，例如通过将其传递给较低级别​​的 API，Rayon 将相应的参数类型限制为 Sync trait bound。这反过来确保闭包内存储的所有内容都是 Sync，因此您不能在闭包中存储任何 RefCell。

遇到这种情况，也可以向编译器寻求解释。例如，如果您尝试编译此代码

use std::cell::RefCell;
use rayon::prelude::*;

fn main() {
    let c = RefCell::new(5);
    let _ = [1, 2, 3]
        .par_iter()
        .map(|i| i * *c.borrow())
        .sum();
}

你会得到这个错误(playground)

error[E0277]: `std::cell::RefCell<i32>` cannot be shared between threads safely
  --> src/main.rs:10:10
   |
10 |         .map(|i| i * *c.borrow())
   |          ^^^ `std::cell::RefCell<i32>` cannot be shared between threads safely
   |
   = help: within `[closure@src/main.rs:10:14: 10:33 c:&std::cell::RefCell<i32>]`, the trait `std::marker::Sync` is not implemented for `std::cell::RefCell<i32>`
   = note: required because it appears within the type `&std::cell::RefCell<i32>`
   = note: required because it appears within the type `[closure@src/main.rs:10:14: 10:33 c:&std::cell::RefCell<i32>]`

虽然不幸的是，编译器没有直接提到 map() 参数的 trait bound，它仍然会为您指出相关方法，并解释说它期望闭包是 同步，以及不同步的原因。