code: def testParallelEnqueue(self):
      with self.session() as sess, self.test_scope():
          q = data_flow_ops.FIFOQueue(10, dtypes_lib.float32)
          elems = [
              10.0,
              20.0,
              30.0,
              40.0,
              50.0,
              60.0,
              70.0,
              80.0,
              90.0,
              100.0,
          ]
          enqueue_ops = [q.enqueue((x,)) for x in elems]
          dequeued_t = q.dequeue()
  
          # Run one producer thread for each element in elems.
          def enqueue(enqueue_op):
              sess.run(enqueue_op)
  
          threads = [
              self.checkedThread(target=enqueue, args=(e,))
              for e in enqueue_ops
          ]
          for thread in threads:
              thread.start()
          for thread in threads:
              thread.join()
  
          # Dequeue every element using a single thread.
          results = []
          for _ in range(len(elems)):
              results.append(self.evaluate(dequeued_t))
          self.assertItemsEqual(elems, results)
  
file_path: tensorflow/tensorflow/compiler/tests/fifo_queue_test.py
imports: import time
  from tensorflow.compiler.tests import xla_test
  from tensorflow.python.framework import dtypes
  from tensorflow.python.ops import data_flow_ops
  from tensorflow.python.platform import test
label_desc: Use image node_id 6 for calling the FIFOQueueTest obj's underlying member method code with example usage: obj.testParallelEnqueue() without return types