如何將對堆棧變量的引用傳遞給線程？我正在編寫一個WebSocket服務器，其中一個Web客戶端連接到一個多線程計算機AI上下棋。WebSocket服務器希望傳遞一個Logger對象進入人工智能代碼。這個Logger對象將把日志行從AI排到Web客戶端。這個Logger必須包含對客戶端連接的引用。我對生命如何與線程交互感到困惑。我用一個Wrapper由類型參數化的結構。這個run_thread函數嘗試展開該值并將其記錄下來。use std::fmt::Debug;use std::thread;struct Wrapper<T: Debug> {
val: T,}fn run_thread<T: Debug>(wrapper: Wrapper<T>) {
let thr = thread::spawn(move || {
println!("{:?}", wrapper.val);
});
thr.join();}fn main() {
run_thread(Wrapper::<i32> { val: -1 });}這個wrapper參數存在于堆棧中，且其生存期不會延長。run_thread的堆?？蚣?，即使在堆棧幀結束之前線程將被連接。我可以從堆棧中復制值：use std::fmt::Debug;use std::thread;struct Wrapper<T: Debug + Send> {
val: T,}fn run_thread<T: Debug + Send + 'static>(wrapper: Wrapper<T>) {
let thr = thread::spawn(move || {
println!("{:?}", wrapper.val);
});
thr.join();}fn main() {
run_thread(Wrapper::<i32> { val: -1 });}如果T是對一個我不想復制的大對象的引用：use std::fmt::Debug;use std::thread;struct Wrapper<T: Debug + Send> {
val: T,}fn run_thread<T: Debug + Send + 'static>(wrapper: Wrapper<T>) {
let thr = thread::spawn(move || {
println!("{:?}", wrapper.val);
});
thr.join();}fn main() {
let mut v = Vec::new();
for i in 0..1000 {
v.push(i);
}
run_thread(Wrapper { val: &v });}其結果是：error: `v` does not live long enough
--> src/main.rs:22:32
|
22 | run_thread(Wrapper { val: &v });
| ^ does not live long enough
23 | }
| - borrowed value only lives until here
|
= note: borrowed value must be valid for the static lifetime...在我真正的程序中，看起來兩個Logger連接對象必須放置在Arc包裝紙?？蛻舳吮灰髮⑦B接放在Arc當代碼被并行化時，代碼是庫內部的。這尤其令人討厭，因為連接的生存期肯定大于工作線程的生存期。我錯過了什么嗎？
2 回答
隔江千里
TA貢獻1906條經驗 獲得超10個贊
Arcsleep
SyncMutexAtomic*
范圍-線程池
use scoped_threadpool::Pool; // 0.1.9use std::{thread, time::Duration};fn main() {
let mut vec = vec![1, 2, 3, 4, 5];
let mut pool = Pool::new(vec.len() as u32);
pool.scoped(|scoped| {
for e in &mut vec {
scoped.execute(move || {
thread::sleep(Duration::from_secs(1));
*e += 1;
});
}
});
println!("{:?}", vec);}橫梁
use crossbeam; // 0.6.0use std::{thread, time::Duration};fn main() {
let mut vec = vec![1, 2, 3, 4, 5];
crossbeam::scope(|scope| {
for e in &mut vec {
scope.spawn(move |_| {
thread::sleep(Duration::from_secs(1));
*e += 1;
});
}
})
.expect("A child thread panicked");
println!("{:?}", vec);}人造絲
use rayon::iter::{IntoParallelRefMutIterator, ParallelIterator}; // 1.0.3use std::{thread, time::Duration};fn main() {
let mut vec = vec![1, 2, 3, 4, 5];
vec.par_iter_mut().for_each(|e| {
thread::sleep(Duration::from_secs(1));
*e += 1;
});
println!("{:?}", vec);}
客戶端必須將連接放在 Arc當代碼被并行化時，代碼是庫內部的。
Arc / Mutex
慕森王
TA貢獻1777條經驗 獲得超3個贊
LoggerCloneArc<Mutex<Connection>>ConnectionArc
添加回答
舉報
0/150
提交
取消