添加任务 :param item: 数据: 支持小于号比较的类 或者 （priority, item） :param ignore_max_size: queue满时是否等待，为True时无视队列的maxsize，直接往里塞 :return:
(self, item, ignore_max_size=False)
| 17 | self.priority_queue = PriorityQueue(maxsize=setting.TASK_MAX_CACHED_SIZE) |
| 18 | |
| 19 | def add(self, item, ignore_max_size=False): |
| 20 | """ |
| 21 | 添加任务 |
| 22 | :param item: 数据: 支持小于号比较的类 或者 （priority, item） |
| 23 | :param ignore_max_size: queue满时是否等待，为True时无视队列的maxsize，直接往里塞 |
| 24 | :return: |
| 25 | """ |
| 26 | if ignore_max_size: |
| 27 | self.priority_queue._put(item) |
| 28 | self.priority_queue.unfinished_tasks += 1 |
| 29 | else: |
| 30 | self.priority_queue.put(item) |
| 31 | |
| 32 | def get(self): |
| 33 | """ |