tobast/distribute_shell_tasks
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Wait before threads start

Browse source
This commit is contained in:
Théophile Bastian 2019-08-29 13:46:07 +02:00
parent 5343142f01
commit 1e9d8d1f44
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
distribute_tasks.py
View file

@ -3,6 +3,7 @@
import threading import threading
import queue import queue
import sys import sys
import time
import yaml import yaml
import paramiko import paramiko
@ -175,6 +176,7 @@ class Orchestrator:
def start(self): def start(self):
for thread in self.threads: for thread in self.threads:
thread.start() thread.start()
time.sleep(0.1)
for thread in self.threads: for thread in self.threads:
while thread.is_alive(): while thread.is_alive():