def __init__(self):
self.tasks_by_path = {}
self.queued_tasks = []
self.semaphore = threading.Semaphore(0)
self._lock = threading.Lock()
微信
公众号
扫码关注公众号