''

def _run(self):

    while self._queue:
        args = self._queue.pop(0)
        if isinstance(args, tuple):
            self._consumer(*args)
        else:
            self._consumer(args)
        time.sleep(self._delay)
    self._is_alive = False
