Traitement parallèle avec multitraitement

#! /usr/local/bin/python
# -*- coding:utf-8

import multiprocessing

def plus_data(num):
    return num+1

def multi_plus_one(before_list):
    pool = multiprocessing.Pool(processes=4)
    return pool.map(plus_data, before_list)

if __name__ == "__main__":
    before_list = range(10)
    print before_list
    #Tout sur les éléments de la liste+1
    print multi_plus_one(before_list)

#! /usr/local/bin/python
# -*- coding:utf-8

import multiprocessing

def plus_data(num, plus_num):
    return num + plus_num

#Wrapper pour multi-piscine
def wrapper_plus_data(args):
    return plus_data(*args)

def multi_plus_one(before_list):
    pool = multiprocessing.Pool(processes=4)
    return pool.map(wrapper_plus_data, before_list)

if __name__ == "__main__":
    before_list = [(i, 2) for i in range(10)]
    #Tout sur les éléments de la liste+2
    print multi_plus_one(before_list)

Recommended Posts