code: def __init__(self, procs, queue, decode):
      self.procs = procs
      self.queue = queue
      self.decode = decode
      self._current = []
      self._sentinel_count = 0
  
file_path: gluonts/src/gluonts/nursery/glide/parallel.py
imports: import multiprocessing
  from functools import partial
  from toolz.itertoolz import partition_all
  from toolz.functoolz import identity
label_desc: Use image node_id 1 to create a new ParApplyIterator object  with example: obj = ParApplyIterator(procs, queue, decode)