code: def test_init_cpu2():
      args = argparse.Namespace(
          multiprocessing_distributed=True,
          dist_world_size=2,
          dist_rank=None,
          ngpu=0,
          local_rank=None,
          dist_launcher=None,
          distributed=True,
          dist_backend="gloo",
          dist_init_method="env://",
          dist_master_addr=None,
          dist_master_port=free_port(),
      )
      args.dist_rank = 0
      option = build_dataclass(DistributedOption, args)
      args.dist_rank = 1
      option2 = build_dataclass(DistributedOption, args)
      with ProcessPoolExecutor(max_workers=2) as e:
          fn = e.submit(_init, option)
          fn2 = e.submit(_init, option2)
          with pytest.raises(RuntimeError):
              fn.result()
              fn2.result()
  
imports: import argparse
  import unittest.mock
  from concurrent.futures.process import ProcessPoolExecutor
  from concurrent.futures.thread import ThreadPoolExecutor
  import pytest
  from espnet2.tasks.abs_task import AbsTask
  from espnet2.train.distributed_utils import DistributedOption, free_port, resolve_distributed_mode
  from espnet2.utils.build_dataclass import build_dataclass
label_desc: Use image node_id 14 for calling a global function with example usage: test_init_cpu2() without return types