看不懂怎么办?跟着代码敲,想加深印象?跟着代码敲
from multiprocessing import Pool
import os,time
def run_pool(name):#进程需要做的事,添加自己的逻辑
print('Run_pool name:(%s) pid :(%s)'% (name,os.getpid()))#打印进程的id和名字
start=time.time()#保存进程运行的时间
time.sleep(2)#等待两秒
end=time.time()#保存进程准备结束的时间
tmp=end-start
print('start - end = %s'% (tmp))#start和end之间的函数共运行了多少秒
if __name__=='__main__':#测试以下代码
print('main process start pid:(%s)'% os.getpid())#查看当前主进程的id
pool=Pool(4)#线程池设置为4
for x in range(4):#循环添加线程
pool.apply_async(run_pool,args=(x,))
pool.close()#关闭线程池
pool.join()#主线程等待其他线程完成后一起释放
print('main process end')#主线程结束,结合上一条代码可以看看这段话是否在最底部
这里只放出线程池的相关内容,其他的请自行理解
Sign in to make a reply
你眼训可以走先JIA
看不懂怎么办?跟着代码敲,想加深印象?跟着代码敲
from multiprocessing import Pool
import os,time
def run_pool(name):#进程需要做的事,添加自己的逻辑
print('Run_pool name:(%s) pid :(%s)'% (name,os.getpid()))#打印进程的id和名字
start=time.time()#保存进程运行的时间
time.sleep(2)#等待两秒
end=time.time()#保存进程准备结束的时间
tmp=end-start
print('start - end = %s'% (tmp))#start和end之间的函数共运行了多少秒
if __name__=='__main__':#测试以下代码
print('main process start pid:(%s)'% os.getpid())#查看当前主进程的id
pool=Pool(4)#线程池设置为4
for x in range(4):#循环添加线程
pool.apply_async(run_pool,args=(x,))
pool.close()#关闭线程池
pool.join()#主线程等待其他线程完成后一起释放
print('main process end')#主线程结束,结合上一条代码可以看看这段话是否在最底部