Code d'implémentation simple du pool de processus en python

Le contenu de cet article concerne le code d'implémentation simple du pool de processus en python. Il a une certaine valeur de référence. Les amis dans le besoin peuvent s'y référer.

Retournez à Python et utilisez le pool de processus de Python.

Je me souviens que lors de l'entretien précédent, l'intervieweur avait demandé : Connaissez-vous les paramètres par défaut du pool de processus ? Je n'ai pas répondu, mais j'ai découvert plus tard qu'il existe des paramètres par défaut. Jetons un coup d'œil à ses paramètres par défaut

1 Aucun paramètre

from multiprocessing.pool import Pool
from time import sleep
def fun(a):
    sleep(5)
    print(a)

if __name__ == '__main__':
    p = Pool()      # 这里不加参数，但是进程池的默认大小，等于电脑CPU的核数
                    # 也是创建子进程的个数，也是每次打印的数字的个数
    for i in range(10):
        p.apply_async(fun, args= (i, ))
    p.close()
    p.join()        # 等待所有子进程结束，再往后执行
    print("end")

2 Ajouter des paramètres 5

from multiprocessing.pool import Pool
from time import sleep
def fun(a):
    sleep(5)
    print(a)
if __name__ == '__main__':
    p = Pool(5)     # 最多执行5个进程，打印5个数
    for i in range(10):
        p.apply_async(fun, args= (i, ))
    p.close()
    p.join()        # 等待所有子进程结束，再往后执行
    print("end")

.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!