python线程池高并发单个函数

在Python中，线程池是一种处理高并发的有效机制，它允许你将任务分发到一组工作线程上，而不是一次性创建所有的线程。当需要同时执行大量独立的任务时，线程池能避免频繁地创建和销毁线程带来的开销，提高效率。

`concurrent.futures`模块提供了ThreadPoolExecutor，用于创建和管理线程池。例如，如果你有一个名为`process_task`的函数你想并行处理，你可以这样做：

from concurrent.futures import ThreadPoolExecutor

def process_task(data):
    # 这里是你的函数逻辑
    pass

# 创建一个线程池
with ThreadPoolExecutor(max_workers=5) as executor:
    futures = [executor.submit(process_task, task_data) for task_data in large_data_list]

# 等待所有任务完成，并收集结果
for future in futures:
    result = future.result()

在这个例子中，`max_workers=5`设置了最多同时运行5个任务。`submit()`方法会提交一个任务给线程池，返回的是一个Future对象，可以用于获取最终的结果。`future.result()`会阻塞直到任务完成并返回结果。