import time
from tqdm import tqdm
import multiprocessing as mp
def pickle_process(_class, *args):
return _class.proc_func(*args)
class OP():
def __init__(self):
self.length = 64
def proc_func(self):
time.sleep(0.1)
def flow(self):
# ------------- 配置好进度条 -------------
pbar = tqdm(total=self.length)
pbar.set_description(' Flow ')
update = lambda *args: pbar.update()
# --------------------------------------
pool = mp.Pool(16)
for _ in range(self.length):
pool.apply_async(pickle_process, args=(self, ), callback=update) # 通过callback来更新进度条
pool.close()
pool.join()
if __name__ == '__main__':
start_time = time.time()
op = OP()
op.flow()
print(time.time() - start_time)
扫码关注腾讯云开发者
领取腾讯云代金券
Copyright © 2013 - 2025 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号:粤B2-20090059 深公网安备号 44030502008569
腾讯云计算(北京)有限责任公司 京ICP证150476号 | 京ICP备11018762号 | 京公网安备号11010802020287
Copyright © 2013 - 2025 Tencent Cloud.
All Rights Reserved. 腾讯云 版权所有