class_docstr: Dispatcher object that communicates and coordinates individual workers.
  
  Warnings
  --------
  There should never be more than one dispatcher running at any one time.
docstr: Atomically add a job to the queue.
  
  Parameters
  ----------
  job : iterable of list of (int, float)
      The corpus in BoW format.
docstr_tok: ["Atomically","add","a","job","to","the","queue",".","Parameters","--","--","--","--","--","job",":","iterable","of","list","of","(","int",",","float",")","The","corpus","in","BoW","format","."]
code: def putjob(self, job):
      """Atomically add a job to the queue.
  
      Parameters
      ----------
      job : iterable of list of (int, float)
          The corpus in BoW format.
  
      """
      self._jobsreceived += 1
      self.jobs.put(job, block=True, timeout=HUGE_TIMEOUT)
      logger.info(
          "added a new job (len(queue)=%i items)", self.jobs.qsize()
      )
  
imports: import argparse
  import os
  import sys
  import logging
  import threading
  import time
  from queue import Queue
  import Pyro4
  from gensim import utils
  from gensim.models.lda_worker import LDA_WORKER_PREFIX
label_desc: Use image node_id 5 for calling the Dispatcher obj's underlying member method code with example usage: obj.putjob(job) without return types