清空自己 :return:
(self)
| 457 | return self.proxy_queue.qsize() if self.proxy_queue is not None else 0 |
| 458 | |
| 459 | def clear(self): |
| 460 | """ |
| 461 | 清空自己 |
| 462 | :return: |
| 463 | """ |
| 464 | self.proxy_queue = None |
| 465 | # {代理ip: ProxyItem, ...} |
| 466 | self.proxy_dict = {} |
| 467 | # 清理失效代理集合 |
| 468 | _limit = datetime.datetime.now() - datetime.timedelta(minutes=10) |
| 469 | self.invalid_proxy_dict = { |
| 470 | k: v for k, v in self.invalid_proxy_dict.items() if v > _limit |
| 471 | } |
| 472 | # 清理超时的update_ts记录 |
| 473 | _limit = time.time() - 600 |
| 474 | self.proxy_item_update_ts_dict = { |
| 475 | k: v for k, v in self.proxy_item_update_ts_dict.items() if v > _limit |
| 476 | } |
| 477 | return |
| 478 | |
| 479 | def get(self, retry: int = 0) -> dict: |
| 480 | """ |
no outgoing calls
no test coverage detected