code: def testShutdownRace(self):
      dataset = dataset_ops.Dataset.range(20)
      map_fn = lambda x: dataset_ops.Dataset.range(20 * x, 20 * (x + 1))
      dataset = dataset.apply(
          interleave_ops.parallel_interleave(
              map_fn,
              cycle_length=3,
              sloppy=False,
              buffer_output_elements=1,
              prefetch_input_elements=0,
          )
      )
      dataset = dataset.batch(32)
  
      results = []
      for _ in range(2):
          elements = []
          next_element = self.getNext(dataset)
          try:
              while True:
                  elements.extend(self.evaluate(next_element()))
          except errors.OutOfRangeError:
              pass
          results.append(elements)
      self.assertAllEqual(results[0], results[1])
  
imports: import itertools
  import math
  import threading
  import time
  from absl.testing import parameterized
  import numpy
  from tensorflow.python.data.experimental.ops import interleave_ops
  from tensorflow.python.data.experimental.ops import testing
  from tensorflow.python.data.kernel_tests import checkpoint_test_base
  from tensorflow.python.data.kernel_tests import test_base
  from tensorflow.python.data.ops import dataset_ops
  from tensorflow.python.data.ops import options
  from tensorflow.python.framework import combinations
  from tensorflow.python.framework import dtypes
  from tensorflow.python.framework import errors
  from tensorflow.python.framework import sparse_tensor
  from tensorflow.python.ops import math_ops
  from tensorflow.python.ops import script_ops
  from tensorflow.python.ops import sparse_ops
  from tensorflow.python.platform import test
label_desc: Use image node_id 13 for calling the ParallelInterleaveTest obj's underlying member method code with example usage: obj.testShutdownRace() without return types