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

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 - 局部函数访问外部变量

相关文章：

c# - Winforms 和后台 worker

java - Java 中的线程池执行器

tuples - 在 Rust 中，如何创建由元组支持的切片？

c - 如何在 Linux 中使用自旋锁？

c# - 启动多个线程时 Silverlight 应用程序没有响应

rust - actix-web 处理程序中的 HTTP 请求 -> 多个执行程序一次 : EnterError

rust - rust 特征。在依赖库中定义它们是习惯的做法，还是可以在使用它们的二进制代码中将Traits添加到类型中？

linux - 为什么 gdb 中的 pthread_mutex_t 结构全为零？

c++ - std::timed_mutex::try_lock* 虚假地失败

java - Java HashMap 会产生死锁吗？