Python3循环创建多线程未关闭及单线程队列执行问题求助

嘿，太懂你这种明明查了一堆资料却卡壳的感觉了——好多SO帖子讲的都是多线程并发跑任务的队列，可你要的是同时只能跑一个任务的队列，方向不对自然行不通。我来给你捋捋问题出在哪，再给你个靠谱的实现方案。

你原来思路的潜在问题 #

你用while True循环+普通列表当队列，大概率会遇到这几个坑：

• 普通列表不是线程安全的：如果有其他线程往列表加任务，和工作线程的取任务操作同时进行，很容易出现数据混乱（比如任务被重复取、或者队列状态不对）；
• 空转浪费CPU：while True一直轮询队列，没任务的时候也在不停跑，占着CPU资源；
• 异常处理缺失：如果某个任务执行抛出异常，没做捕获的话，整个工作线程直接挂掉，后面的任务就没人处理了。

靠谱的实现方案：用标准库queue.Queue #

Python标准库的queue.Queue就是专门干这事的——它天生线程安全，自带阻塞等待机制，完美匹配你“同时只跑一个任务”的需求。直接上代码：

import queue
import threading
import time

def task_worker(task_queue):
    # 工作线程永久运行，直到主程序退出
    while True:
        # 阻塞等待队列里的任务，不用自己轮询
        task = task_queue.get()
        try:
            # 这里替换成你的实际任务逻辑
            print(f"开始执行任务: {task}")
            time.sleep(2)  # 模拟任务耗时操作
            print(f"任务 {task} 执行完成")
        except Exception as e:
            # 捕获任务异常，避免线程挂掉
            print(f"任务 {task} 执行出错: {str(e)}")
        finally:
            # 必须标记任务完成，否则队列的join()会一直等待
            task_queue.task_done()

# 创建无界队列（也可以设置maxsize限制队列长度）
task_queue = queue.Queue()

# 只启动一个工作线程——这就保证了同时只有一个任务在运行
worker_thread = threading.Thread(
    target=task_worker,
    args=(task_queue,),
    daemon=True  # 设置为守护线程，主程序退出时自动结束
)
worker_thread.start()

# 测试添加任务
task_queue.put("用户上传文件处理")
task_queue.put("数据库备份")
task_queue.put("生成报表")

# 等待所有任务执行完毕（如果不需要等可以去掉这行）
task_queue.join()
print("所有任务都搞定啦！")

为什么这个方案好用？ #

• 线程安全：queue.Queue内部已经帮你处理了锁的问题，不用自己加threading.Lock来保护队列操作；
• 阻塞等待：task_queue.get()会自动阻塞，直到有任务进来，不会空转浪费CPU；
• 异常防护：try/finally确保就算任务出错，线程也不会挂掉，还能正确标记任务完成；
• 自动管理线程：守护线程设置让你不用手动去终止工作线程，主程序退出时它会跟着结束。

如果你之前试过类似方案没成功，大概率是没注意task_done()的调用——如果忘了这一步，queue.join()会一直阻塞下去，或者队列的状态会出问题。

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