Home
last modified time | relevance | path

Searched refs:handler (Results 1 – 6 of 6) sorted by relevance

/DADK/dadk-user/src/scheduler/
H A Dtask_deque.rs52 let handler = std::thread::spawn(move || { in build_install_task() localVariable
55 TID_EID.lock().unwrap().insert(handler.thread().id(), id); in build_install_task()
56 self.queue.push(handler); in build_install_task()
77 let handler = in clean_task() localVariable
79 self.queue.push(handler); in clean_task()
H A Dtask_deque.rs52 let handler = std::thread::spawn(move || { in build_install_task() localVariable
55 TID_EID.lock().unwrap().insert(handler.thread().id(), id); in build_install_task()
56 self.queue.push(handler); in build_install_task()
77 let handler = in clean_task() localVariable
79 self.queue.push(handler); in clean_task()
H A Dmod.rs434 let handler = std::thread::spawn(move || { in run_with_topo_sort() localVariable
438 handler.join().expect("Could not join deamon"); in run_with_topo_sort()
449 let handler = std::thread::spawn(move || { in run_without_topo_sort() localVariable
453 handler.join().expect("Could not join deamon"); in run_without_topo_sort()
H A Dmod.rs434 let handler = std::thread::spawn(move || { in generate_task_target()
438 handler.join().expect("Could not join deamon"); in generate_task_target()
449 let handler = std::thread::spawn(move || { in run()
453 handler.join().expect("Could not join deamon"); in run()
479 let handler = std::thread::spawn(move || { run_with_topo_sort() localVariable
494 let handler = std::thread::spawn(move || { run_without_topo_sort() localVariable
H A Dmod.rs434 let handler = std::thread::spawn(move || { in generate_task_target()
438 handler.join().expect("Could not join deamon"); in generate_task_target()
449 let handler = std::thread::spawn(move || { in run()
453 handler.join().expect("Could not join deamon"); in run()
479 let handler = std::thread::spawn(move || { run_with_topo_sort() localVariable
494 let handler = std::thread::spawn(move || { run_without_topo_sort() localVariable
H A Dmod.rs434 let handler = std::thread::spawn(move || { in generate_task_target()
438 handler.join().expect("Could not join deamon"); in generate_task_target()
449 let handler = std::thread::spawn(move || { in run()
453 handler.join().expect("Could not join deamon"); in run()
477 let handler = std::thread::spawn(move || { run_with_topo_sort() localVariable
492 let handler = std::thread::spawn(move || { run_without_topo_sort() localVariable