class_docstr: An offline predictor worker that takes input and produces output by queue.
  Each process will exit when they see :class:`DIE`.
class_docstr_tok: ["An","offline","predictor","worker","that","takes","input","and","produces","output","by","queue",".","Each","process","will","exit","when","they","see",":","class",":","`","DIE","`","."]
code: def run(self):
      self._init_runtime()
      while True:
          tid, dp = self.inqueue.get()
          if tid == DIE:
              self.outqueue.put((DIE, None))
              return
          else:
              self.outqueue.put((tid, self.predictor(*dp)))
  
imports: import multiprocessing
  import numpy
  from concurrent.futures import Future
  import tensorflow
  from six.moves import queue, range
  from ..compat import tfv1
  from ..tfutils.model_utils import describe_trainable_vars
  from ..utils import logger
  from ..utils.concurrency import DIE, ShareSessionThread, StoppableThread
  from .base import AsyncPredictorBase, OfflinePredictor, OnlinePredictor
label_desc: Use image node_id 2 for calling the MultiProcessQueuePredictWorker obj's underlying member method code with example usage: obj.run() without return types