Lines Matching defs:enqueue
51 enqueue_op = q.enqueue((10.0,))
60 enqueue_correct_op = q.enqueue(([[1.0, 2.0], [3.0, 4.0], [5.0, 6.0]],))
64 q.enqueue(([[1.0, 2.0, 3.0], [4.0, 5.0, 6.0]],))
75 q2.enqueue(([1, 2, 3],))
83 q.enqueue([9, [10]]).run()
99 enqueue_ops = [q.enqueue((x,)) for x in elems]
103 def enqueue(enqueue_op):
108 target=enqueue, args=(e,)) for e in enqueue_ops
125 enqueue_ops = [q.enqueue((x,)) for x in elems]
128 # Enqueue every element using a single thread.
149 enqueue_ops = [q.enqueue((x,)) for x in elems]
162 enqueue_ops = [q.enqueue((x,)) for x in elems]
165 def enqueue():
178 enqueue_thread = self.checkedThread(target=enqueue)
192 enqueue_ops = [q.enqueue((x, y)) for x, y in elems]
212 enqueue_op = q.enqueue((10.0,))
251 enqueue_op = q.enqueue((10.0,))
261 enqueue_op = q.enqueue((10.0,))
271 enqueue_op = q.enqueue((constant_op.constant(
292 enqueue_op = q.enqueue((constant_op.constant(
443 # Enqueue 100 items in parallel on 10 threads.
444 def enqueue():
447 threads = [self.checkedThread(target=enqueue) for _ in range(10)]
538 def enqueue():
547 enqueue_thread = self.checkedThread(target=enqueue)
565 def enqueue():
574 enqueue_thread = self.checkedThread(target=enqueue)
890 enqueue_op = q.enqueue((10.0,))
919 blocking_enqueue_op = q.enqueue((50.0,))
981 blocking_enqueue_op = q.enqueue((50.0,))
1009 # Wait for the close op to block before unblocking the enqueue.
1048 "Blocking enqueue op did not execute within the expected time.")
1064 # At this point the close operation will complete, so the next enqueue
1073 q1.enqueue((10.0,)).run()
1096 q2.enqueue((20.0,)).run()
1114 q1.enqueue((10.0,)).run()
1202 # Enqueue/Dequeue into a dynamically selected queue
1206 q.enqueue((10.,)).run()
1247 enqueue_op = q_full.enqueue((6.0,))
1392 # The enqueue should start and then block.
1394 results.append(deq.eval()) # Will only complete after the enqueue starts.
1422 enq_list = [q.enqueue((e,)) for e in elem]
