借用官网例子说明我的疑问： with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor: # Start the load operations and mark each future with its URL future_to_url = {executor.submit(load_url, url, 60): url for url in URLS} for future in concurrent.futures.as_completed(future_to_url): ...
官网的例子都是这样，将所有任务一次性放到 executor 后才使用 as_completed 判断。
如果我需要从队列中不断取任务的话，该怎么使用 as_completed 比较合适呢？ # 类似于这个意思 while True: executor.submit(load_url) time.sleep(1) while True: for future in concurrent.futures.as_completed(): #do sth...
使用两个线程？感觉在套娃……
或者说 ThreadPoolExecutor 不适用于该场景，需要自己写 threading 方法?