def _check_time_queue(self):
        now = time.time()
        self.mutex.acquire()
        while self.time_queue.qsize() and self.time_queue.top and self.time_queue.top.exetime < now:
            task = self.time_queue.get_nowait()
            task.exetime = 0
            self.priority_queue.put(task)
        self.mutex.release()
dataset/ETHPy150Open binux/pyspider/pyspider/scheduler/task_queue.py/TaskQueue._check_time_queue/original