code: def _pool_map(data):
      global SHARED_ARR, WORKER_ID, MAP_FUNC
      res = MAP_FUNC(data)
      if res is None:
          return None
      shared = np.reshape(SHARED_ARR, res.shape)
      assert shared.dtype == res.dtype
      shared[:] = res
      return WORKER_ID
  
imports: import copy
  import ctypes
  import multiprocessing
  import numpy
  import threading
  import zmq
  from six.moves import queue
  from ..utils.concurrency import StoppableThread, enable_death_signal
  from ..utils.serialize import dumps_once, loads_once
  from .base import DataFlow, DataFlowReentrantGuard, ProxyDataFlow
  from .common import RepeatedData, BatchData
  from .parallel import _bind_guard, _get_pipe_name, _MultiProcessZMQDataFlow, _repeat_iter, _zmq_catch_error
label_desc: Use image node_id 1 for calling a global function with example usage: _pool_map(data) and returns: WORKER_ID, None