Einfacher Implementierungscode des Prozesspools in Python

Der Inhalt dieses Artikels befasst sich mit dem einfachen Implementierungscode des Prozesspools in Python. Ich hoffe, dass er für Freunde hilfreich ist.

Gehen Sie zurück zu Python und verwenden Sie den Prozesspool von Python.

Ich erinnere mich, dass der Interviewer im vorherigen Interview gefragt hat: Kennen Sie die Standardparameter des Prozesspools? Ich habe nicht geantwortet, aber später habe ich herausgefunden, dass es Standardparameter gibt. Werfen wir einen Blick auf die Standardparameter

Keine Parameter

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. Fügen Sie Parameter 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")

Das obige ist der detaillierte Inhalt vonEinfacher Implementierungscode des Prozesspools in Python. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!