binux / pyspider

            self.priority_queue.put(task)

        self.mutex.release()

    def _check_processing(self):

        now = time.time()

        self.mutex.acquire()

        while self.processing.qsize() and self.processing.top and self.processing.top.exetime < now:

            task = self.processing.get_nowait()

            if task.taskid is None:

                continue

            task.exetime = 0

            self.priority_queue.put(task)

            logger.info("processing: retry %s", task.taskid)

        self.mutex.release()

    def put(self, taskid, priority=0, exetime=0):

        '''Put a task into task queue'''

        self._check_time_queue()

        self._check_processing()

    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()

    def _check_processing(self):

        now = time.time()