Searched refs:input_queue (Results 1 – 8 of 8) sorted by relevance
| /external/toolchain-utils/bestflags/ |
| D | steering_test.py | 108 input_queue = manager.Queue()
113 args=(set(), [current_generation], input_queue, result_queue))
129 input_queue.put(task)
155 input_queue = manager.Queue()
160 args=(steering_tasks, [current_generation], input_queue, result_queue))
|
| D | steering.py | 14 def Steering(cache, generations, input_queue, result_queue): argument
70 if input_queue.empty():
76 task = input_queue.get()
|
| D | testing_batch.py | 295 input_queue = manager.Queue()
299 args=(set(), generations, output_queue, input_queue))
306 task = input_queue.get()
|
| /external/rust/crates/parking_lot/src/ |
| D | condvar.rs | 758 let input_queue = Arc::new(Mutex::new(Queue::new())); in run_queue_test() localVariable
767 input_queue.clone(), in run_queue_test()
781 input_queue.clone(), in run_queue_test()
798 let mut input_queue = input_queue.lock(); in run_queue_test() localVariable
799 input_queue.should_continue = false; in run_queue_test()
818 input_queue: Arc<Mutex<Queue>>, in consumer_thread()
828 let mut queue = input_queue.lock(); in consumer_thread()
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | meta_graph_test.py | 713 input_queue = data_flow_ops.FIFOQueue(10, dtypes.float32)
714 enqueue = input_queue.enqueue((9876), name="enqueue")
715 close = input_queue.close(name="close")
716 qr = queue_runner_impl.QueueRunner(input_queue, [enqueue], close)
718 input_queue.dequeue(name="dequeue")
|
| /external/tensorflow/tensorflow/python/ops/numpy_ops/g3doc/ |
| D | TensorFlow_Numpy_Distributed_Image_Classification.ipynb | 432 " def _replica_fn(device, input_queue, output_queue):\n",
434 " inputs = input_queue.get()\n",
450 " for input_queue, replica_input, in zip(self.input_queues, all_inputs):\n",
451 " input_queue.put(replica_input)\n",
|
| /external/tensorflow/tensorflow/python/training/ |
| D | server_lib_test.py | 296 input_queue = input_ops.input_producer(constant_op.constant(
298 self.assertIsNotNone(input_queue)
|
| D | saver_test.py | 1891 input_queue = data_flow_ops.FIFOQueue(
1893 qr = queue_runner_impl.QueueRunner(input_queue, [count_up_to])
|