
开启多线程执行某个函数
import threading
def run_in_threads(func, n, *args, **kwargs):
'''
对某个函数开启多线程执行,可用于快速造数(使用方式参考当前文件的main方法)
:param func: 开启多线程的目标函数
:param n: 线程数量
:param args: 被调用的函数位置参数
:param kwargs: 被调用的函数关键字参数
:return:
'''
threads = []
logger.info("即将开启{}个线程执行函数:{}".format(n,func))
for _ in range(n):
thread = threading.Thread(target=func, args=args, kwargs=kwargs)
threads.append(thread)
thread.start()
logger.info("线程{},启动".format(_))
# 关闭线程
for thread in threads:
thread.join()
logger.info("线程{},关闭".format(thread.name))
if __name__ == '__main__':
run_in_threads(要开启多线程的函数A,线程数,函数A的入参们)
本文是原创文章,完整转载请注明来自 Lo
评论
匿名评论
隐私政策
你无需删除空行,直接评论以获取最佳展示效果