获取任务 :return:
(self)
| 30 | self.priority_queue.put(item) |
| 31 | |
| 32 | def get(self): |
| 33 | """ |
| 34 | 获取任务 |
| 35 | :return: |
| 36 | """ |
| 37 | try: |
| 38 | item = self.priority_queue.get(timeout=1) |
| 39 | return item |
| 40 | except: |
| 41 | return |
| 42 | |
| 43 | def empty(self): |
| 44 | return self.priority_queue.empty() |
no outgoing calls
no test coverage detected