如何等待任何工作线程的完成？

import threading

def worker():
    # 工作线程的具体逻辑
    print("Worker thread is running")

# 创建并启动工作线程
thread = threading.Thread(target=worker)
thread.start()

# 等待工作线程的完成
thread.join()

print("All worker threads have completed")

import concurrent.futures

def worker():
    # 工作线程的具体逻辑
    print("Worker thread is running")

# 创建线程池
thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=5)

# 提交工作任务给线程池执行
thread_pool.submit(worker)

# 等待所有工作线程的完成
thread_pool.shutdown(wait=True)

print("All worker threads have completed")