python使用 multiprocessing 多进程处理批量数据的示例代码

import multiprocessing
def process_data(data):
    # 这里是处理单个数据的过程
    return data * 2
# 待处理的数据
data = [1, 2, 3, 4, 5]
def normal_func():
    # 普通处理方式
    result = []
    for obj in data:
        result.append(process_data(obj)
    return result
def parallel_func():
    # 多进程处理方式
    pool = multiprocessing.Pool(multiprocessing.cpu_count())
    result = pool.map(process_data, data)
    pool.close()
    return result
if __name__ == '__main__':
    result = normal_func()
    result = parallel_func()