Python多线程池的使用方法

Python的concurrent.futures库提供了ThreadPoolExecutor类，它是一个高效的线程池实现

1. 导入所需模块：

import concurrent.futures 

2. 定义一个函数，该函数将在线程池中运行：

def my_function(x):     # 在这里执行你的任务     return x * x 

3. 创建一个ThreadPoolExecutor实例，并指定线程池中的最大线程数。然后，使用submit()方法将任务添加到线程池中：

with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:     # 提交任务并将Future对象存储在列表中     futures = [executor.submit(my_function, i) for i in range(10)] 

4. 使用as_completed()方法迭代已完成的任务，并获取结果：

for future in concurrent.futures.as_completed(futures):     result = future.result()     print(result) 

下面是一个完整的示例：

import concurrent.futures  def my_function(x):     return x * x  with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:     futures = [executor.submit(my_function, i) for i in range(10)]  for future in concurrent.futures.as_completed(futures):     result = future.result()     print(result) 

这个示例将创建一个包含5个线程的线程池，并将10个任务提交给线程池。每个任务都会计算一个数字的平方。当任务完成时，它们的结果将按照完成顺序打印出来。