多进程优化

parent 11f5ac90
...@@ -94,6 +94,9 @@ class DataIntegrate: ...@@ -94,6 +94,9 @@ class DataIntegrate:
self.single_fund_data_list = [] self.single_fund_data_list = []
portfolio_evaluation = self.portfolio_diagnose.old_portfolio_evaluation() portfolio_evaluation = self.portfolio_diagnose.old_portfolio_evaluation()
radar_chart_data = self.portfolio_diagnose.single_fund_radar() radar_chart_data = self.portfolio_diagnose.single_fund_radar()
with futures.ProcessPoolExecutor(os.cpu_count()) as executor:
res = executor.map(gen_radar_chart, radar_chart_data)
res = list(res)
for i in range(len(portfolio_evaluation)): for i in range(len(portfolio_evaluation)):
if portfolio_evaluation[i]['status'] == '保留': if portfolio_evaluation[i]['status'] == '保留':
portfolio_evaluation[i]['status'] = '<div class="self_type fl">保留</div>' portfolio_evaluation[i]['status'] = '<div class="self_type fl">保留</div>'
...@@ -107,7 +110,7 @@ class DataIntegrate: ...@@ -107,7 +110,7 @@ class DataIntegrate:
'fund_name': portfolio_evaluation[i]['name'], 'fund_name': portfolio_evaluation[i]['name'],
'status': portfolio_evaluation[i]['status'], 'status': portfolio_evaluation[i]['status'],
'evaluation': portfolio_evaluation[i]['data'], 'evaluation': portfolio_evaluation[i]['data'],
'radar_chart_path': gen_radar_chart(radar_chart_data[i]) 'radar_chart_path': res[i]
}) })
def get_old_compare_pic(self): def get_old_compare_pic(self):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment