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

#Hier parallel verarbeiten
def func(n, argument1, argument2):
    #Der Prozess des Verdoppelns und Addierens 5
    return n * argument1 + argument2

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

def multi_process(sampleList):
    #Anzahl der Prozesse:8(Parallelverarbeitung mit 8 CPU)
    p = Pool(8)
    output = p.map(wrapper, sampleList)
    #Ende des Prozesses
    p.close()
    return output

if __name__ == "__main__":
    #Führen Sie 100 Prozesse parallel durch
    num = 100

    # (i, 2, 5)Ist das Argument
    sampleList = [(i, 2, 5) for i in range(num)]

    #Verdoppeln Sie die Elemente von sampleList und fügen Sie 5 hinzu
    output = multi_process(sampleList)

Recommended Posts