需要参照极简多线程
极简多线程
threads = []
info_list = []
for index, value in enumerate(l):
start = value
end = value + step
sql_conn = Oracle(JndiNames.EPO_DS)
t = MyThread(DalMaterialInfo(sql_conn).download_material_info_start_end, param, start, end, sql_conn)
t.start()
threads.append(t)
for index, t in enumerate(threads):
info_dict = {}
t.join()
info_dict[f'{index}'] = t.get_result()
# print('info dict', info_dict)
info_list.append(info_dict)
# print('info_list',info_list)
print('len info list', len(info_list))
"""
用类包装线程;调用时可以获取线程的return返回值
"""
# 定义一个MyThread.py线程类
class MyThread(threading.Thread):
def __init__(self, func, args=()):
super(MyThread, self).__init__()
self.func = func
self.args = args
def run(self):
time.sleep(2)
self.result = self.func(*self.args)
def get_result(self):
threading.Thread.join(self) # 等待线程执行完毕
try:
return self.result
except Exception:
参考
https://blog.csdn.net/xpt211314/article/details/109543014



