python 中如何退出线程

Question

大家好，我正在用 python 编写套接字编程并使用多线程，但是当我想退出程序时遇到一个问题，似乎我无法退出正在运行的线程。

我的代码图片

def create_workers():
for _ in range(NUMBER_OF_THREADS):
    t = threading.Thread(target=work)
    t.daemon = True  # End the Thread
    t.start()



def work():
    while True:

        x = queue.get()
        if x == 1:
            create_socket()
            bind_socket()
            accept_connections()
        if x == 2:
            start_turtle()
            break

        queue.task_done()

函数create_workers正在运行两个线程并且目标函数工作，但我不这样做在函数工作中打破 while 循环后真的知道终止它

Answer 1

使用 threading.Event实例作为您在 work 结束之前设置的标志，并检查它是否在无限循环的每次迭代开始时设置。

如果您的 work 函数更复杂，有多个 return 语句，您可以将 event.set() 调用放入 finally 中try 语句的 块。

threading.Event 是线程安全的。

正如user2357112 支持 Monica 所指出的，使线程成为守护进程没有意义，所以我删除了该行。

def create_workers():
    event = threading.Event()
    for _ in range(NUMBER_OF_THREADS):
        t = threading.Thread(target=work, args=(event,))
        t.start()

def work(event):
    while True:
        if event.is_set():
            return
        
        x = queue.get()
        if x == 1:
            create_socket()
            bind_socket()
            accept_connections()
        if x == 2:
            start_turtle()
            break
        
        queue.task_done()
    
    event.set()

Answer 2

您可以使用python-worker（链接）

from worker import abort_all_thread

## your running code

abort_all_thread() # this will kill any active threads