This commit is contained in:
griffi-gh 2023-11-20 19:51:16 +01:00
parent 298c959d73
commit 93f3066ee0

View file

@ -13,7 +13,7 @@ struct Task<T> {
fn task_loop<T, R>() { fn task_loop<T, R>() {
let tasks = VecDeque::<Task<T>>::new(); let tasks = VecDeque::<Task<T>>::new();
loop { loop {
//todo
}; };
} }
@ -22,7 +22,7 @@ impl<T: 'static, R: 'static> KubiPool<T, R> {
Self { Self {
callback, callback,
threads: (0..threads).map(|_| { threads: (0..threads).map(|_| {
std::thread::spawn(task_loop::<T, R>) std::thread::spawn(move || task_loop::<T, R>())
}).collect(), }).collect(),
} }
} }