本文共 707 字,大约阅读时间需要 2 分钟。
多进程 Multiprocessing 和多线程 threading 类似, 他们都是在 python 中用来并行运算的,用来弥补 threading 的一些劣势
该Process对象与Thread对象的用法相同,拥有is_alive()、join([timeout])、run()、start()、terminate(),close()等方法
from multiprocessing import Pool as ProcessPoolpool = ProcessPool(8)res = pool.map(process, userlist)pool.close()pool.join()def process(each_user): item= each_user.item itemListTmp = [] itemListTmp .append(item) return (each_user,set(itemListTmp)) #返回结果
2
import multiprocessing as mpdef job(x): return x*xdef multicore(): pool = mp.Pool(processes=3) #参数可以无 res = pool.map(job, range(10)) print(res) if __name__ == '__main__': multicore()#结果[0, 1, 4, 9, 16, 25, 36, 49, 64, 81]
其他具体参考:
转载地址:http://pmhdi.baihongyu.com/