管理当前在执行的任务,如果任务结束,从self._running_task列表中删除
(self)
| 15 | self._running_task = [] # 记录当前在执行的任务列表 |
| 16 | |
| 17 | def _handle_exist_task(self): |
| 18 | """管理当前在执行的任务,如果任务结束,从self._running_task列表中删除 |
| 19 | """ |
| 20 | for task in self._running_task[:]: |
| 21 | if task.done: |
| 22 | LogPrinter.info(f'Task_{task.task_id} is done.') |
| 23 | self._running_task.remove(task) |
| 24 | |
| 25 | def run(self): |
| 26 | """任务执行 |