帮我写一个线程池处理多线程用python

在Python中，可以使用内置的`concurrent.futures`模块来创建和管理线程池，以便高效地处理多线程任务。这里是一个简单的例子，展示了如何创建一个线程池并使用它来并发执行函数：

import concurrent.futures

def worker_func(arg):
    """代表你要并发执行的每个任务"""
    # 这里替换为实际的任务代码
    print(f"Worker {arg} is running...")
    time.sleep(2)  # 模拟耗时操作
    print(f"Worker {arg} finished.")

# 创建线程池
with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
    # 提交任务到线程池
    future_to_work = {executor.submit(worker_func, i): i for i in range(10)}

    # 等待所有任务完成，并打印结果
    for future in concurrent.futures.as_completed(future_to_work):
        try:
            arg = future_to_work[future]
            result = future.result()
            print(f"Result from worker {arg}: {result}")
        except Exception as exc:
            print(f"Exception happened: {exc}")

在这个例子中，我们创建了一个最大工作线程数为5的线程池。`worker_func`是一个模拟的工作函数，你可以将其替换成你需要执行的实际业务逻辑。通过`submit`方法将任务提交给线程池，然后使用`as_completed`遍历已完成的任务。