code: def test_run_in_parallel(self):
      b = Barrier(3)
      pool = run_parallel.RunParallel()
      out = pool.run([b.wait, b.wait, b.wait])
      self.assertCountEqual(out, [0, 1, 2])
      pool.shutdown()
  
file_path: pysc2/pysc2/lib/run_parallel_test.py
imports: import threading
  from absl.testing import absltest
  from pysc2.lib import run_parallel
label_desc: Use image node_id 2 for calling the RunParallelTest obj's underlying member method code with example usage: obj.test_run_in_parallel() without return types