class_docstr: Internal class for `parallel_map`, arguments match the constructor's.
class_docstr_tok: ["Internal","class","for","`","parallel_map","`",",","arguments","match","the","constructor","'s","."]
docstr: Pulls a chunk from the source iterable and submits it to the
  pool; must be run from the main thread.
  
  Returns
  -------
  `True` if any job was submitted (that is, if there was any chunk
  left to process), `False` otherwise.
docstr_tok: ["Pulls","a","chunk","from","the","source","iterable","and","submits","it","to","the","pool",";","must","be","run","from","the","main","thread",".","Returns","--","--","--","-","`","True","`","if","any","job","was","submitted","(","that","is",",","if","there","was","any","chunk","left","to","process",")",",","`","False","`","otherwise","."]
code: def _enqueue_job(self):
      """Pulls a chunk from the source iterable and submits it to the
      pool; must be run from the main thread.
  
      Returns
      -------
      `True` if any job was submitted (that is, if there was any chunk
      left to process), `False` otherwise.
      """
      # immediately deplete the input stream of chunk_size elems (or less)
      chunk = list(itertools.islice(self.source_it, self.chunk_size))
  
      # empty chunk? then we finished iterating over the input stream
      if len(chunk) == 0:
          self.depleted_source = True
          return False
  
      future = self.executor.submit(
          _chunk_process_wrapper, self.fn, chunk
      )
      future.add_done_callback(self._bump_processed_count)
      self.future_chunks.append(future)
  
      return True
  
file_path: speechbrain/speechbrain/utils/parallel.py
imports: import itertools
  import multiprocessing
  from collections import deque
  from concurrent.futures import Executor, ProcessPoolExecutor
  from threading import Condition
  from typing import Any, Callable, Iterable, Optional
  from tqdm.auto import tqdm
label_desc: Use image node_id 4 for calling the _ParallelMapper obj's underlying member method code with example usage: obj._enqueue_job() and returns: True, False