Python多进程加快for循环速度
你可以使用Python的multiprocessing
模块来将for
循环改为多进程实现。下面是一个简单的示例代码,演示了如何使用multiprocessing.Pool
来并行执行一个for循环:
import multiprocessing# 定义一个函数,该函数会在每个进程中执行
def process_item(item):# 这里可以放入你原来在for循环中的处理逻辑# 这个函数将会被并行地调用result = item * 2return resultif __name__ == "__main__":# 要处理的数据列表data = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]# 创建一个进程池,使用多个进程并行处理数据with multiprocessing.Pool(processes=multiprocessing.cpu_count()) as pool:# 使用map函数将数据分发到各个进程中执行results = pool.map(process_item, data)# 输出处理结果print("处理结果:", results)
在这个示例中,process_item
函数会被并行地应用到data
列表中的每个元素上,然后pool.map
会等待所有的进程完成,并返回结果列表。