'Args:
idx, config: same as in :class:`MultiProcessPredictWorker`.
inqueue (multiprocessing.Queue): input queue to get data point. elements are (task_id, dp)
outqueue (multiprocessing.Queue): output queue to put result. elements are (task_id, output)'

def __init__(self, idx, inqueue, outqueue, config):

    super(MultiProcessQueuePredictWorker, self).__init__(idx, config)
    self.inqueue = inqueue
    self.outqueue = outqueue
    assert isinstance(self.inqueue, multiprocessing.queues.Queue)
    assert isinstance(self.outqueue, multiprocessing.queues.Queue)
