code: def __init__(self, ds, buffer_size, strict=False):
      super(_ParallelMapData, self).__init__(ds)
      assert buffer_size > 0, buffer_size
      self._buffer_size = buffer_size
      self._buffer_occupancy = (
          0  # actual #elements in buffer, only useful in strict mode
      )
      self._strict = strict
  
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 to create a new _ParallelMapData object from inherited base classes: ProxyDataFlow with example: obj = _ParallelMapData(ds, buffer_size, strict)