                       self.__class__.__name__, self._name, processes)
  
          self.procs = self.set_procs(processes)
          ctx = mp.get_context("spawn")
          self.pool = ctx.Pool(processes=self.procs)
  
          self._method = method
          self._kwargs = self.build_target_kwargs(in_queue, out_queue, kwargs)
          self._args = args
  
          logger.debug("Initialized %s: '%s'", self.__class__.__name__, self._name)
 
</s> remove         logger_init = kwargs["log_init"]
        log_queue = kwargs["log_queue"]
        logger_init(self.loglevel, log_queue)
 </s> add  </s> remove         kwargs["log_init"] = set_root_logger
        kwargs["log_queue"] = LOG_QUEUE
 </s> add  </s> remove         logger_init = kwargs["log_init"]
        log_queue = kwargs["log_queue"]
        logger_init(self.loglevel, log_queue)
 </s> add 
        self.pool = ctx.Pool(processes=self.procs,
                             initializer=set_root_logger,
                             initargs=(logger.getEffectiveLevel(), LOG_QUEUE))
                       self.__class__.__name__, self._name, processes)
  
          self.procs = self.set_procs(processes)
          ctx = mp.get_context("spawn")
        self.pool = ctx.Pool(processes=self.procs,
                             initializer=set_root_logger,
                             initargs=(logger.getEffectiveLevel(), LOG_QUEUE))
        self.pool = ctx.Pool(processes=self.procs,
                             initializer=set_root_logger,
                             initargs=(logger.getEffectiveLevel(), LOG_QUEUE))
          self._method = method
          self._kwargs = self.build_target_kwargs(in_queue, out_queue, kwargs)
          self._args = args
  
          logger.debug("Initialized %s: '%s'", self.__class__.__name__, self._name)
keep keep keep keep replace replace keep keep keep keep keep
 Move mp logging functions to multithreading module 
lib/multithreading.py