class_docstr: Dispatcher object that communicates and coordinates individual workers.
  
  Warnings
  --------
  There should never be more than one dispatcher running at any one time.
class_docstr_tok: ["Dispatcher","object","that","communicates","and","coordinates","individual","workers",".","Warnings","--","--","--","--","There","should","never","be","more","than","one","dispatcher","running","at","any","one","time","."]
docstr: Partly initialize the dispatcher.
  
  A full initialization (including initialization of the workers) requires a call to
  :meth:`~gensim.models.lsi_dispatcher.Dispatcher.initialize`
  
  Parameters
  ----------
  maxsize : int, optional
      Maximum number of jobs to be kept pre-fetched in the queue.
docstr_tok: ["Partly","initialize","the","dispatcher",".","A","full","initialization","(","including","initialization","of","the","workers",")","requires","a","call","to",":","meth",":","`","~gensim.models.lsi_dispatcher.Dispatcher.initialize","`","Parameters","--","--","--","--","--","maxsize",":","int",",","optional","Maximum","number","of","jobs","to","be","kept","pre-fetched","in","the","queue","."]
code: def __init__(self, maxsize=0):
      """Partly initialize the dispatcher.
  
      A full initialization (including initialization of the workers) requires a call to
      :meth:`~gensim.models.lsi_dispatcher.Dispatcher.initialize`
  
      Parameters
      ----------
      maxsize : int, optional
          Maximum number of jobs to be kept pre-fetched in the queue.
  
      """
      self.maxsize = maxsize
      self.workers = {}
      self.callback = None
  
imports: import os
  import sys
  import logging
  import argparse
  import threading
  import time
  from queue import Queue
  import Pyro4
  from gensim import utils
label_desc: Use image node_id 1 to create a new Dispatcher object  with example: obj = Dispatcher(maxsize)