进程模块,multiprocessing 的 Process
进程的创建 变量 = Process(target = 指定函数,args = (1,))指定函数参数
这样我们就创建了一个进程,target 无需加括号!
我们通过 变量.start() 调用某进程, 然后使用:变量.join()阻塞母进程,
让母进程等待子进程执行完毕.否则就母进程先执行了,
那样就达不到我们想要的结果了.
有的时候有可能串行比并行要快,并行来回切换有可能用的时间更长!
假设中间有停顿的话,比如time.sleep(2) 那么并行一定比串行快.
并行两个sleep同时运行,所以要快,串行则需要执行两遍sleep,时间长的多.
a = Process(target = 函数,args = 函数参数) 函数无需加括号
a.start() 启动进程 a.join() 阻塞母进程,让子进程先执行.
from multiprocessing import Pool,cpu_count
import os,time
def long_time_task(i):
print(‘我是子进程:{},进程ID:{}‘.format(i,os.getpid()))
time.sleep(2) #当某进程执行到这时,因为需要等待时间,所以系统自动跳到下个进程
#把需要等待时间的进程前部,逐一执行!,后面又重新逐一调用等待时间后的进程
#也就是阻塞住了,所以利用阻塞的时间启动下个进程,当第1个进程执行完阻塞前和阻塞后的任务是,
#才能进入新的进程!
print(i,‘结果:{}‘.format(8**20))
if __name__ == ‘__main__‘:
start = time.time()
print(‘cpu内核数:{}‘.format(cpu_count()))
print(‘当前母进程:{}‘.format(os.getpid()))
p = Pool(4) #创建进程池
for i in range(5): #
p.apply_async(long_time_task,args=(i,))
print(‘等待子进程执行!‘)
p.close() #关闭进程池,并启动4个进程,第5个进程则需要等第1个的进程完毕才能进入
p.join() #阻塞进程池的进程
print(‘总用时:{}‘.format(time.time() - start)) #得出总时长
原文:https://www.cnblogs.com/lc1013/p/10306482.html