Processes / Threads
Depending on your unit resources, you might want to use Threads over Processes.
This can be quickly modified in the captain.py
file, by replacing all ProcessPoolExecutor
to ThreadPoolExecutor
.
captain.py
from concurrent.futures import P̶r̶o̶c̶e̶s̶s̶P̶o̶o̶l̶E̶x̶e̶c̶u̶t̶o̶r ThreadPoolExecutor # Replace here
[...]
def prepare_agents(agent_args):
[...]
with P̶r̶o̶c̶e̶s̶s̶P̶o̶o̶l̶E̶x̶e̶c̶u̶t̶o̶r ThreadPoolExecutor(max_workers=workers_cnt) as ex: # Replace here
[...]