#!/usr/bin/env python
# -*- coding: utf-8 -*-
from multiprocessing import Pool
from collections import Counter

#Traiter ici en parallèle
def func(n, argument1, argument2):
    #Le processus de doubler et d'ajouter 5
    return n * argument1 + argument2

def wrapper(args):
    #args(i, 2, 5)Est devenu
    return func(*args)

def multi_process(sampleList):
    #Nombre de processus:8(Traitement parallèle avec 8 cpu)
    p = Pool(8)
    output = p.map(wrapper, sampleList)
    #Fin du processus
    p.close()
    return output

if __name__ == "__main__":
    #Effectuer 100 processus en parallèle
    num = 100

    # (i, 2, 5)Est l'argument
    sampleList = [(i, 2, 5) for i in range(num)]

    #Doublez les éléments de sampleList et ajoutez 5
    output = multi_process(sampleList)

Recommended Posts