Python -检查队列中的所有任务是否都已完成

import threading
import time

# 模拟任务
def task():
    time.sleep(1)  # 模拟任务执行时间
    print("任务完成")

# 创建任务队列
task_queue = []

# 创建线程锁
lock = threading.Lock()

# 添加任务到队列
def add_task():
    for i in range(5):
        lock.acquire()  # 获取锁
        task_queue.append(threading.Thread(target=task))
        lock.release()  # 释放锁

# 检查队列中的任务是否都已完成
def check_tasks():
    while True:
        lock.acquire()  # 获取锁
        if len(task_queue) == 0:
            lock.release()  # 释放锁
            break
        lock.release()  # 释放锁
        time.sleep(0.5)  # 检查间隔

# 启动任务添加线程
add_task_thread = threading.Thread(target=add_task)
add_task_thread.start()

# 启动任务检查线程
check_tasks_thread = threading.Thread(target=check_tasks)
check_tasks_thread.start()

# 等待任务添加线程和任务检查线程结束
add_task_thread.join()
check_tasks_thread.join()

print("所有任务已完成")