Searched defs:input_queue (Results 1 – 3 of 3) sorted by relevance
14 def Steering(cache, generations, input_queue, result_queue): argument
136 let input_queue = match self.input.as_mut() { in start_receive_queue() localVariable
986 let input_queue = Arc::new(Mutex::new(Queue::new())); in run_queue_test() localVariable1026 let mut input_queue = input_queue.lock(); in run_queue_test() localVariable