diff --git a/kubi-pool/src/lib.rs b/kubi-pool/src/lib.rs index 066aa53..ae1e8c1 100644 --- a/kubi-pool/src/lib.rs +++ b/kubi-pool/src/lib.rs @@ -13,7 +13,7 @@ struct Task { fn task_loop() { let tasks = VecDeque::>::new(); loop { - //todo + }; } @@ -22,7 +22,7 @@ impl KubiPool { Self { callback, threads: (0..threads).map(|_| { - std::thread::spawn(task_loop::) + std::thread::spawn(move || task_loop::()) }).collect(), } }