code: def get_forkpool(num_workers, init_worker=None, closing=True):
      pool = multiprocessing.Pool(
          processes=num_workers, initializer=init_worker
      )
      return contextlib.closing(pool) if closing else pool
  
file_path: autodist/examples/benchmark/utils/recommendation/popen_helper.py
imports: import contextlib
  import multiprocessing
  import multiprocessing.pool
label_desc: Use image node_id 1 for calling a global function with example usage: get_forkpool(num_workers, init_worker, closing) and returns: unknown