gpt4 book ai didi

multithreading - 生成线程时无法共享Arc变量

转载 作者:行者123 更新时间:2023-12-03 11:43:17 25 4
gpt4 key购买 nike

我有以下结构来表示服务器对象:

pub struct Server {
client_managers: Arc<ClientManager>,
listener: Option<TcpListener>,
}

这是接收客户端连接并在新线程中处理它的代码:
fn serve(&self) {
for stream in self.listener.as_ref().unwrap().incoming() {
match stream {
Ok(stream) => {
let client_manager = &mut self.client_managers.clone();
// let client_manager = Arc.new(self.client_managers);
thread::spawn(move || {
client_manager.do_something();

});
}
Err(e) => {
println!("connection error: {}", e);
}
}
}
}

但是,编译时出现以下错误:
error[E0716]: temporary value dropped while borrowed
--> server/src/server.rs:37:47
|
37 | let client_manager = &mut self.client_managers.clone();
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ creates a temporary which is freed while still in use
38 | // let client_manager = Arc.new(self.client_managers);
39 | / thread::spawn(move || {
40 | | client_manager.nothing();
41 | | });
| |______________________- argument requires that borrow lasts for `'static`
42 | }
| - temporary value is freed at the end of this statement

我了解为什么会发生此错误。我的问题是:

1)我通过在线阅读一些教程来使用Arc。 ( Example)但是为什么他们的例子有用却不是我的?

2)如何根据自己的情况解决此错误? (我仍然想共享对象 client_manager)。

最佳答案

thread::spawn采取的闭合是'static,这意味着它不能从线程外部借用数据。但是,此行将克隆Arc并借用它,并将借用的引用传递给线程:

let client_manager = &mut self.client_managers.clone();
thread::spawn(move || {
client_manager.do_something();
// ^-- client_manager is a `&mut Arc<_>` borrowed from outside the thread
});

相反,您想要的只是克隆 Arc,而不在将其传递到线程之前以任何方式借用它:

let client_manager = self.client_managers.clone();
thread::spawn(move || {
client_manager.do_something();
// ^-- client_manager is a `Arc<_>` owned by the new thread
});
Arc具有对该值的共享所有权,因此,仅当引用该值的所有 Arc指针超出范围(甚至跨线程)时,它才被销毁。

关于multithreading - 生成线程时无法共享Arc变量,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61163510/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com