Searched defs:input_queue (Results 1 – 2 of 2) sorted by relevance
14 def Steering(cache, generations, input_queue, result_queue): argument
772 let input_queue = Arc::new(Mutex::new(Queue::new())); in run_queue_test() localVariable812 let mut input_queue = input_queue.lock(); in run_queue_test() localVariable