      # <<< THREAD METHODS >>> #
      def _compile_threads(self):
          """ Compile the threads into self._threads list """
          logger.debug("Compiling %s threads", self._plugin_type)
          self._add_thread("{}_input".format(self._plugin_type),
                           self.process_input,
                           self._queues["in"],
                           self._queues["predict"])
          self._add_thread("{}_predict".format(self._plugin_type),
                           self._predict,
 
</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         The normalization method is dictated by the command line argument `-nh (--normalization)`
 </s> add         The normalization method is dictated by the normalization command line argument </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["post"],
 </s> add                          self._queues["post_{}".format(name)], </s> remove             # Ensure tensorflow doesn't pin all threads to one core when using tf-mkl
 </s> add             # Ensure tensorflow doesn't pin all threads to one core when using Math Kernel Library
        name = self.name.replace(" ", "_").lower()
        base_name = "{}_{}".format(self._plugin_type, name)
        self._add_thread("{}_input".format(base_name),
      # <<< THREAD METHODS >>> #
      def _compile_threads(self):
          """ Compile the threads into self._threads list """
          logger.debug("Compiling %s threads", self._plugin_type)
        name = self.name.replace(" ", "_").lower()
        base_name = "{}_{}".format(self._plugin_type, name)
        self._add_thread("{}_input".format(base_name),
                           self.process_input,
                           self._queues["in"],
                           self._queues["predict"])
          self._add_thread("{}_predict".format(self._plugin_type),
                           self._predict,
keep keep keep keep replace keep keep keep keep keep
 Extraction - Auto generate Components and Extended Masks 
plugins/extract/_base.py