检查任务是否超时,如果超时,终止任务 :return: True | False
(self)
| 107 | self._task_proc = None |
| 108 | |
| 109 | def _check_task_expired(self): |
| 110 | """检查任务是否超时,如果超时,终止任务 |
| 111 | |
| 112 | :return: True | False |
| 113 | """ |
| 114 | if self._task_expired_time: |
| 115 | if time.time() > self._task_expired_time: |
| 116 | self.terminate() # 终止任务 |
| 117 | self.code = errcode.E_NODE_TASK_EXPIRED |
| 118 | self.msg = u"任务(id:%d, name:%s)执行超时。" % (self.task_id, self.task_name) |
| 119 | return True |
| 120 | else: |
| 121 | return False |
| 122 | |
| 123 | def _check_task_done(self): |
| 124 | """检查任务是否执行完毕 |
no test coverage detected