用 ThreadPoolExecutor 时如何同时 submit 和 as_completed？

借用官网例子说明我的疑问：

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 方法?