(self, executor)
| 4240 | is_shutdown = False |
| 4241 | |
| 4242 | def __init__(self, executor): |
| 4243 | self._queue = queue.PriorityQueue() |
| 4244 | self._scheduled_tasks = set() |
| 4245 | self._count = count() |
| 4246 | self._executor = executor |
| 4247 | |
| 4248 | Thread.__init__(self, name="Task Scheduler") |
| 4249 | self.daemon = True |
| 4250 | self.start() |
| 4251 | |
| 4252 | def shutdown(self): |
| 4253 | try: |