                           self._queues["predict"],
                           self._queues["post"])
          self._add_thread("{}_output".format(self._plugin_type),
                           self.process_output,
                           self._queues["post"],
                           self._queues["out"])
          logger.debug("Compiled %s threads: %s", self._plugin_type, self._threads)
  
      def _add_thread(self, name, function, in_queue, out_queue):
          """ Add a MultiThread thread to self._threads """
 
</s> remove                          self._queues["predict"],
                         self._queues["post"])
        self._add_thread("{}_output".format(self._plugin_type),
 </s> add                          self._queues["predict_{}".format(name)],
                         self._queues["post_{}".format(name)])
        self._add_thread("{}_output".format(base_name), </s> remove                          self._queues["predict"])
        self._add_thread("{}_predict".format(self._plugin_type),
 </s> add                          self._queues["predict_{}".format(name)])
        self._add_thread("{}_predict".format(base_name), </s> remove         self._add_thread("{}_input".format(self._plugin_type),
 </s> add         name = self.name.replace(" ", "_").lower()
        base_name = "{}_{}".format(self._plugin_type, name)
        self._add_thread("{}_input".format(base_name), </s> remove         if masker is not None and masker.lower() != "none":
            retval.append("mask")
 </s> add         for idx, mask in enumerate(masker):
            if mask is not None and mask.lower() != "none":
                retval.append("mask_{}".format(idx))
                         self._queues["post_{}".format(name)],
                           self._queues["predict"],
                           self._queues["post"])
          self._add_thread("{}_output".format(self._plugin_type),
                           self.process_output,
                         self._queues["post_{}".format(name)],
                           self._queues["out"])
          logger.debug("Compiled %s threads: %s", self._plugin_type, self._threads)
  
      def _add_thread(self, name, function, in_queue, out_queue):
          """ Add a MultiThread thread to self._threads """
keep keep keep keep replace keep keep keep keep keep
 Extraction - Auto generate Components and Extended Masks 
plugins/extract/_base.py