multithreading - 如何在没有Arc的线程中使用互斥锁？

Question

Closed. This question needs to be more focused。它当前不接受答案。












想要改善这个问题吗？更新问题，使它仅关注 editing this post的一个问题。

在4个月前关闭。



Improve this question




我有一个应该在给定范围内搜索素数的函数。 (该算法并不重要；请忽略它效率很低的事实。)

use std::thread;
use std::sync::Mutex;
use std::convert::TryInto;

/// Takes the search range as (start, end) and outputs a vector with the primes found within
/// that range.
pub fn run(range: (u32, u32)) -> Vec<u32> {
    let mut found_primes: Mutex<Vec<u32>> = Mutex::new(Vec::new());

    let num_threads: usize = 8;
    let num_threads_32: u32 = 8;
    let join_handles: Vec<thread::JoinHandle<()>> = Vec::with_capacity(num_threads);

    // ERROR: `found_primes` does not live long enough
    let vec_ref = &found_primes;
    for t in 0..num_threads_32 {

        thread::spawn(move || {
            let mut n = range.0 + t;
            'n_loop: while n < range.1 {
                for divisor in 2..n {
                    if n % divisor == 0 {
                        n += num_threads_32;
                        continue 'n_loop;
                    }
                }
                // This is the part where I try to add a number to the vector
                vec_ref.lock().expect("Mutex was poisoned!").push(n);

                n += num_threads_32;
            }

            println!("Thread {} is done.", t);
        });
    }

    for handle in join_handles {
        handle.join();
    }

    // ERROR: cannot move out of dereference of `std::sync::MutexGuard<'_, std::vec::Vec<u32>>`
    *found_primes.lock().expect("Mutex was poisoned!")
}

我设法使它与 std::sync::mpsc 一起工作，但是我很确定它可以仅通过互斥体来完成。但是，借阅检查器不喜欢它。
错误在注释中。我(认为我)理解第一个错误:删除 &found_primes后(函数返回时)，编译器无法证明不会在线程内使用 found_primes，即使我在此之前对所有线程进行 .join()。我猜想我需要不安全的代码才能使其正常工作。我不明白第二个错误。
有人可以解释错误并告诉我如何仅使用 Mutex es吗？

最佳答案

最后一个错误是提示试图将内容移出互斥量。 .lock()返回仅产生对内容的引用的MutexGuard。您不能离开它，否则它将使互斥体处于无效状态。您可以通过克隆获得拥有的值，但是如果互斥量消失了，则不必这样做。
您可以使用 .into_inner() 使用互斥量并返回其中的内容。

found_primes.into_inner().expect("Mutex was poisoned!")

请参阅此修补程序以及 playground上的其他链接的修补程序。

关于multithreading - 如何在没有Arc的线程中使用互斥锁？ ，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/64625328/

上一篇：rust - 在dylib中调用外部函数

下一篇：function - 局部函数访问外部变量

相关文章：

segmentation-fault - 在 Rust 中调用 llvm_sys 的 LLVMCreateTargetMachine 生成目标文件时出现段错误

rust - 如何编写采用字符串迭代器的特征方法，避免单态化(静态分派(dispatch))？

c - 使用循环缓冲区和生产者/消费者设计模式时是否需要互斥锁

c - 如果一个线程锁定了一个互斥量并且没有解锁它，那么其他线程不应该被阻塞吗？

multithreading - 我可以安全地对不应该是多线程的东西进行多线程处理吗？

c++ - 多线程概念题

python - 在 python 中处理大量数据，我应该使用多线程/进程吗？

c++ - 如何在同一个函数上编写 pthread_create？

java - 在线程中设置事件监听器

rust - 方法返回具有相同生命周期的结构迭代器的生命周期

Answer 1

最后一个错误是提示试图将内容移出互斥量。 .lock()返回仅产生对内容的引用的MutexGuard。您不能离开它，否则它将使互斥体处于无效状态。您可以通过克隆获得拥有的值，但是如果互斥量消失了，则不必这样做。
您可以使用 .into_inner() 使用互斥量并返回其中的内容。

found_primes.into_inner().expect("Mutex was poisoned!")

请参阅此修补程序以及 playground上的其他链接的修补程序。