class_docstr: Distributor using a multiprocessing Pool to calculate the jobs in parallel on the local machine.
class_docstr_tok: ["Distributor","using","a","multiprocessing","Pool","to","calculate","the","jobs","in","parallel","on","the","local","machine","."]
docstr: Creates a new MultiprocessingDistributor instance
  
  :param n_workers: How many workers should the multiprocessing pool have?
  :type n_workers: int
  :param disable_progressbar: whether to show a progressbar or not.
  :type disable_progressbar: bool
  :param progressbar_title: the title of the progressbar
  :type progressbar_title: basestring
  :param show_warnings: whether to show warnings or not.
  :type show_warnings: bool
docstr_tok: ["Creates","a","new","MultiprocessingDistributor","instance",":","param","n_workers",":","How","many","workers","should","the","multiprocessing","pool","have","?",":","type","n_workers",":","int",":","param","disable_progressbar",":","whether","to","show","a","progressbar","or","not",".",":","type","disable_progressbar",":","bool",":","param","progressbar_title",":","the","title","of","the","progressbar",":","type","progressbar_title",":","basestring",":","param","show_warnings",":","whether","to","show","warnings","or","not",".",":","type","show_warnings",":","bool"]
code: def __init__(
      self,
      n_workers,
      disable_progressbar=False,
      progressbar_title="Feature Extraction",
      show_warnings=True,
  ):
      """
      Creates a new MultiprocessingDistributor instance
  
      :param n_workers: How many workers should the multiprocessing pool have?
      :type n_workers: int
      :param disable_progressbar: whether to show a progressbar or not.
      :type disable_progressbar: bool
      :param progressbar_title: the title of the progressbar
      :type progressbar_title: basestring
      :param show_warnings: whether to show warnings or not.
      :type show_warnings: bool
      """
      self.pool = Pool(
          processes=n_workers,
          initializer=initialize_warnings_in_workers,
          initargs=(show_warnings,),
      )
      self.n_workers = n_workers
      self.disable_progressbar = disable_progressbar
      self.progressbar_title = progressbar_title
  
imports: import itertools
  import math
  import warnings
  from collections.abc import Generator, Iterable
  from functools import partial
  from itertools import islice, repeat, takewhile
  from multiprocessing import Pool
  from tqdm import tqdm
  from tsfresh.feature_extraction.data import TsData
label_desc: Use image node_id 1 to create a new MultiprocessingDistributor object from inherited base classes: IterableDistributorBaseClass with example: obj = MultiprocessingDistributor(n_workers, disable_progressbar, progressbar_title, show_warnings)