multithreading - 同时将相同的可变函数应用于同一Vec的不同元素

This question already has answers here:

How do I pass disjoint slices from a vector to different threads?

(1个答案)

How can I pass a reference to a stack variable to a thread?

(1个答案)

在6个月前关闭。

我有一系列不想复制的大型结构，并且想对它们应用慢速功能。由于慢速功能可以独立地应用于每个大结构，因此我想同时进行。
所有这些大结构都在容器中(Vec很好地表示了这一点)。我无法为Vec的每个元素生成线程，因为借用一个可变元素与每次借用整个向量是相同的。

struct SomeBigStruct {
    pub variable: i32,
}

impl SomeBigStruct {
    pub fn new() -> SomeBigStruct {
        SomeBigStruct { variable: 0 }
    }
}

fn some_slow_function(struct_in: &mut SomeBigStruct) {
    println!("{}", struct_in.variable);
    struct_in.variable += 1;
}

fn main() {
    let mut vec_of_big_struct: Vec<SomeBigStruct> = Vec::new();

    for i in 0..10 {
        vec_of_big_struct.push(SomeBigStruct::new());
    }
    for struct_to_edit in vec_of_big_struct.iter_mut() {
        some_slow_function(struct_to_edit);
    } //Compiles but is slow

    for struct_to_edit in vec_of_big_struct.iter_mut() {
        std::thread::spawn(move || {
            some_slow_function(struct_to_edit);
        });
    } //Can't compile because borrow checker isn't happy
}

这些不是实际的结构或函数，但是实现细节并不重要。
重要的是我不想复制大结构，因为它很大，并且我想在知道该执行是独立的情况下，在该结构的可变引用上并发运行该函数。

最佳答案

All those big structs are in a container (a Vec is a good representation of that). I can't spawn a thread for each element of the vec, because borrowing one mutable element is the same as borrowing the whole vector each time.

不完全正确，如果您要索引是，那是因为借用检查器无法静态地知道所有索引都不同，因此&mut v[a]和&mut v[b]可以与a == b一起运行，然后由于您对同一事物有两个可变引用而被破坏了这是被禁止的。
迭代器不是问题，您可以同时可变地借用几项:https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=657d45a4a4749ad6568a360d7fa3a08c
但是，顺序的for循环是顺序的。手动处理并发将是一件痛苦的事情(更不用说，即使您的功能有些慢，每个元素产生一个线程也可能比您获得的 yield 要慢得多，创建线程很昂贵)。
我强烈建议您使用rayon，这正是它的用途，并且它提供了par_iter_mut方法，它看起来与您要查找的内容完全一样

vec_of_big_struct.par_iter_mut().for_each(some_slow_function)

或遵循这些思路的方法就可以解决问题。

关于multithreading - 同时将相同的可变函数应用于同一Vec的不同元素，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/64117093/

上一篇：rust - VecDeque和Vec是否都具有特征？

下一篇：rust - 为什么我不能借用我所借的东西，为什么我可以移动方法的自身？

asynchronous - 如何在不使用任何外部依赖项的情况下执行异步/等待功能？

rust - "covering"类型的要求到底是什么？为什么单个元素元组可以满足它？

c# - 如何通过方法参数锁定？

java - 模拟的GUI渲染

Java ExecutorService - 如果 awaitTermination() 失败怎么办？

java - 无法通过 UI 从 AsyncTask 发回数据

parsing - 如何在 Nom 中解析大写字符串？

rust - 如何向特定线程发送消息？

使用数组参数从 C 调用 Rust 方法