队列阻塞主线程

Question

我有一个用于 3 个项目的 for 循环。在for 循环内，我为每个项目生成 15 个线程。这些都将数据返回到我的 GUI，但发生的是 for 循环执行，所有 3 个项目都运行完毕，并产生了 45 个线程。我正在尝试运行第一项，等到 15 个线程完成，然后运行第二项。我需要在不使用join() 的情况下完成所有这些操作。

我认为这可以通过queue 完成，但在阻止时遇到了麻烦。当我尝试以下操作时，它永远不会移动到第二组 15 个线程：

while True:
    try:
        data = q.get(False)
    except Query.Empty():
        data = None

这停止了阻塞问题，并使用 15 个线程中的每一个线程中执行的函数不断更新我的 GUI，但是一旦它们执行，它就会简单地结束并且不会继续 for 循环。这是有问题的循环：

def thing_1(names):
    def thready():
        print "Hello!"
        q.put("Done")
    for name in names:
        print "Working on " + name
        t1 = threading.Thread(target=thready)
        t1.start()
        # Then put 'while True' here

Answer 1

当活动线程数降至 1（假设您没有任何其他活动线程）时，通过打破while True 循环可以很容易地解决这个问题。试试

while True:
    try:
        data = q.get(False)
    except Query.Empty():
        data = None
    if threading.active_count() == 1:
        break

您可以改为使用与现在相同的循环体，但将 while 条件更改为

while threading.active_count() > 1: