timer.py 文件源码

def rebuild_heap(self):
        '''
        ?????cancel?timer?????,????
        :return:
        '''
        import heapq
        tmp_timer_lst = []
        for timer in self.heap.queue:
            # ???????cancel ?timer ????????
            if timer.canceled:
                continue
            tmp_timer_lst.append(timer)

        # ????,??????????cancel????
        self.heap.queue = tmp_timer_lst
        heapq.heapify(self.heap.queue)
        self.cancel_timer_count = 0