Python 多进程池

Posted 2022-03-28 callyblog

def get_html(n):
    time.sleep(n)
    print("sub_progress success")
    return n

# 多进程池 
　　pool = multiprocessing.Pool(multiprocessing.cpu_count())
    result = pool.apply_async(get_html, args=(3,)) # 类似线程池中的sumbmit

    #等待所有任务完成
    pool.close() # 在join前，必须先关闭，停止接收
    pool.join()

    print(result.get())

 

def get_html(n):
    time.sleep(n)
    print("sub_progress success")
    return n

pool = multiprocessing.Pool(multiprocessing.cpu_count())

for result in pool.imap(get_html, [1,5,3]): # 会按照顺序输出
        print(" sleep success".format(result))

 

def get_html(n):
    time.sleep(n)
    print("sub_progress success")
    return n

pool = multiprocessing.Pool(multiprocessing.cpu_count())
    for result in pool.imap_unordered(get_html, [1,5,3]): # 不会按照顺序输出
        print(" sleep success".format(result))