(self)
| 51 | self._thread_stop = False |
| 52 | |
| 53 | def run(self): |
| 54 | self._thread_stop = False |
| 55 | while not self._thread_stop: |
| 56 | try: |
| 57 | request = self._collector.get_request() |
| 58 | if not request: |
| 59 | if not self.is_show_tip: |
| 60 | log.debug("等待任务...") |
| 61 | self.is_show_tip = True |
| 62 | continue |
| 63 | |
| 64 | self.is_show_tip = False |
| 65 | self.deal_request(request) |
| 66 | |
| 67 | except Exception as e: |
| 68 | log.exception(e) |
| 69 | |
| 70 | def is_not_task(self): |
| 71 | return self.is_show_tip |
nothing calls this directly
no test coverage detected