Python：线程只能启动一次

Question

我想在 python 中做线程。我有 100 个单词，想把它们放在 6 个不同的链接中。如果其中一个链接准备好，我希望该链接可以获取新单词。这虽然其他线程仍然在工作中的第一个词。完成 100 个关键字后，应该允许我的完整程序先执行更多代码。我有以下代码：

threads = []

def getresults(seed):
    for link in links:
        t = threading.Thread(target=getLinkResult, args = (suggestengine, seed))
        threads.append(t)
    for thread in threads:
        thread.start()

for seed in tqdm:
    getresults(seed + a)
    getresults(seed + b)

for thread in threads:
    thread.join()

#code that should happen after

我现在收到一个错误： 线程只能启动一次

Answer 1

您调用了两次getresults，两次都引用了同一个全局threads 列表。这意味着，当您第一次调用 getresults 时，线程会启动。

当您第二次调用它们时，之前已经运行的线程会再次调用.start() 方法。

您应该将getresults 中的线程作为本地线程启动，然后将它们附加到全局threads 列表中。

尽管您可以执行以下操作：

for thread in threads:
    if not thread.is_alive():
        thread.start()

它不能解决问题，因为一个或多个线程可能已经结束并因此重新启动，因此会导致相同的错误。

Answer 2

您应该只在 getresults 中启动新线程

threads = []

def getresults(seed):
  local_threads = []
  for link in links:
      t = threading.Thread(target=getLinkResult, args = (suggestengine, seed))
      local_threads.append(t)
      threads.append(t)
  for thread in local_threads:
      thread.start()

for seed in tqdm:
  getresults(seed + a)
  getresults(seed + b)

for thread in threads:
        thread.join()

Answer 3

最快的方式，但不是最聪明的（一般问题）：

from tkinter import *
import threading, time

def execute_script():
    def sub_execute():
        print("Wait 5 seconds")
        time.sleep(5)
        print("5 seconds passed by")
    threading.Thread(target=sub_execute).start()

root = Tk()
button_1 = Button(master=root, text="Execute Script", command=execute_script)
button_1.pack()
root.mainloop()

Answer 4

错误是明确的。您启动线程两次，而您不应该这样做。

getresults(seed + a)
getresults(seed + b)

当您对这些调用进行排序时，您会启动两次线程循环。要正确地做你想做的事，你可以创建一个thread pool and a task queue。基本上，您需要第二个要处理的单词列表和一个互斥锁。每个线程都会锁定互斥体，读取一个单词并将其出队，然后解锁并处理该单词。