random_shuffle_queue_test.py | 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): function in function:RandomShuffleQueueTest.testParallelEnqueue 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 165 def enqueue(): function in function:RandomShuffleQueueTest.testEnqueueAndBlockingDequeue 444 def enqueue(): function in function:RandomShuffleQueueTest.testParallelEnqueueMany 538 def enqueue(): function in function:RandomShuffleQueueTest.testBlockingDequeueMany 565 def enqueue(): function in function:RandomShuffleQueueTest.testBlockingDequeueUpTo [all...] |