jeffemmett
/
cadCAD
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

restart threads

This commit is contained in:
Joshua E. Jodesty 2019-08-27 14:46:16 -04:00
parent 6489a75f1e
commit 8768819790
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cadCAD/engine/simulation.py
View File

@ -222,10 +222,15 @@ class Executor:
return first_timestep_per_run return first_timestep_per_run
tp = TPool(runs)
pipe_run: List[List[Dict[str, Any]]] = flatten( pipe_run: List[List[Dict[str, Any]]] = flatten(
TPool().map( tp.map(
lambda run: execute_run(sweep_dict, states_list, configs, env_processes, time_seq, run), lambda run: execute_run(sweep_dict, states_list, configs, env_processes, time_seq, run),
list(range(runs)) list(range(runs))
) )
) )
# tp.close()
# tp.join()
tp.clear()
return pipe_run return pipe_run