multiprocessing用例

from multiprocessing import Pool
import time,random


def fun(x):

    print(str(x))
    time.sleep(random.randrange(3, 5))
    
if __name__=="__main__":
    pool = Pool(8)
    for i in range(80):
        pool.apply_async(func=fun,args=(i,))
        print('-------------')
    print('go')
    pool.close()
    print('close')
    pool.join()
    print('ok')
for i in range(5):
        s = multiprocessing.Process(target=main,args=('a',))
        s.start()
        l.append(s)
    for i in l:  无法控制进程数量 而Pool可以.
        i.join()
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。