我看了你这段结合Queue和ThreadPoolExecutor的代码，目前的调度逻辑有两个核心问题：一是executor.submit的参数没补全，二是循环终止条件不明确，很容易导致程序卡在q.get()上。咱们一步步来调整：

首先补全基础的submit调用 #

你代码里的executor.submit(worker,...应该补全参数，把parent和q传进去：

future = executor.submit(worker, parent, q)

核心调度逻辑优化：跟踪活跃任务+正确的终止条件 #

原来的while True会在队列空的时候一直阻塞在q.get()，但此时可能还有线程在运行，后续会往队列里添加新的child1/child2。所以我们需要：

• 跟踪活跃任务数，确保所有任务都执行完毕，且队列为空时才退出循环
• 处理队列空但还有活跃任务的情况，避免程序提前退出或卡死

这里可以用threading.Lock来保护对活跃任务数的修改，完整代码如下：

from concurrent.futures import ThreadPoolExecutor
from queue import Queue, Empty
import threading

def func(parent):
    return parent//2, parent//2, parent<=2

def worker(parent, q, active_tasks, lock):
    # 任务开始，活跃数+1
    with lock:
        active_tasks[0] += 1
    
    child1, child2, end = func(parent)
    print(parent)
    if not end:
        q.put(child1)
        q.put(child2)
    
    # 任务结束，活跃数-1
    with lock:
        active_tasks[0] -= 1

if __name__ == "__main__":
    q = Queue()
    q.put(100)
    executor = ThreadPoolExecutor(max_workers=6)
    # 用列表存活跃数（因为int是不可变类型，列表可以在函数内修改）
    active_tasks = [0]
    lock = threading.Lock()

    while True:
        try:
            # 设置超时，避免一直阻塞在空队列
            parent = q.get(timeout=1)
            executor.submit(worker, parent, q, active_tasks, lock)
            q.task_done()  # 标记队列任务已处理
        except Empty:
            # 队列为空时，检查是否还有活跃任务
            with lock:
                if active_tasks[0] == 0:
                    print("所有任务执行完毕，退出")
                    break
            # 还有活跃任务，继续等待
            continue

    executor.shutdown()  # 关闭线程池，等待所有任务完成

关键逻辑说明 #

• 活跃任务数跟踪：用active_tasks列表配合lock，确保多线程下修改计数的安全性，避免竞态条件
• 队列超时获取：q.get(timeout=1)避免队列空时永久阻塞，每隔1秒检查一次是否还有活跃任务
• q.task_done()：标记队列中的任务已被取出处理，规范队列的使用逻辑
• executor.shutdown()：必须调用，确保线程池优雅关闭，等待所有提交的任务执行完毕

内容的提问来源于stack exchange，提问作者Kevin Fang