mutex 相关问题

我有一些网址，然后我将其分成块并同时迭代它们，使用克隆将结果保存在 vec 中： pub fn Collect_parm_list(url_list: Vec) -> 结果我有一些 url，然后我将其分成块并同时迭代它们，使用克隆将结果保存在 vec 中： pub fn collect_parm_list(url_list: Vec<String>) -> Result<Vec<String>, Box<dyn std::error::Error>> { let shared_id_list = Arc::new(Mutex::new(vec![])); for chunk in url_list.chunks(20) { let mut handles = vec![]; for url in chunk { let id_list = Arc::clone(&shared_id_list); let handle = thread::spawn(move || { // total: optionSale -> result -> total let mut id_list_v = id_list.lock().unwrap(); id_list_v.push(url.to_string()) }); handles.push(handle); } // Wait for all threads to complete for handle in handles { handle.join().unwrap(); } } let x = shared_id_list.lock().unwrap(); Ok(x.to_vec()) } 我借用数据时出错： url_listdoes not live long enough borrowed value does not live long enough at：用于 url_list.chunks(20) { 中的块你的问题是 .chunks() 不返回拥有的东西的迭代器，它返回一个切片。在这种情况下，这意味着当您有一个 Vec<String> 时，.chunks() 会为您提供一个 &[String] 的迭代器，这意味着 url 是一个 &String。然后，您尝试将其传递给传递给 thread::spawn 的闭包，但提供给该函数的闭包必须是 'static，这意味着它们不会从任何当地人那里借用。请注意，即使您连接了所有线程句柄，这也是有问题的。但借用检查员并不知道会发生这种情况。一个简单的修复方法是在生成线程之前添加 let url = url.to_owned();，这将创建 url 的独立副本，然后闭包将捕获它。或者，您可以使用作用域线程。这可以让您避免复制 url，但它也可以让您从输出列表中消除 Arc 层。（您仍然需要 Mutex 来同步访问。）这还允许您在线程完成时在 .into_inner() 上使用 Mutex，因为您知道此时没有线程仍然具有访问权限，因此您可以在不使用它的情况下使用它。等待锁定。这种方法的代码最终也变得简单得多： pub fn collect_parm_list(url_list: Vec<String>) -> Vec<String> { let id_list = Mutex::new(vec![]); thread::scope(|s| { for chunk in url_list.chunks(20) { for url in chunk { s.spawn(|| { // total: optionSale -> result -> total let mut id_list_v = id_list.lock().unwrap(); id_list_v.push(url.to_string()) }); } } }); id_list.into_inner().unwrap() }

multithreading rust mutex

回答 1 投票 0

基于锁的并发向量

考虑基于 std::vector 的基于锁的并发向量，并为 std::vector 公共成员函数的每次调用锁定互斥锁，如何通过并发安全地迭代线程

c++ multithreading mutex concurrent-vector

回答 1 投票 0

C++中unique_lock和shared_lock有什么区别

尝试了解何时可以使用shared_lock而不是unique_lock，反之亦然。 C++ 文档非常神秘！我知道一般准则是如果我们愿意的话，在两者上使用 lock_guard

c++ multithreading mutex

回答 1 投票 0

mutex 相关问题

最新问题