aljaz/Interlace
1
1
Fork 0
mirror of https://github.com/codingo/Interlace.git synced 2025-12-17 06:44:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

Changed to ensure Interlace waits for the thread to finish

Browse Source
This commit is contained in:
prodigysml
2021-02-23 00:59:06 +11:00
parent aec744ffdf
commit b11e9db2a5
1 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
Interlace/lib/threader.py
View File

@@ -47,23 +47,24 @@ class Task(object):
return self.self_lock return self.self_lock
def _run_task(self, t=False): def _run_task(self, t=False):
if t:
s = subprocess.Popen(self.task, shell=True, s = subprocess.Popen(self.task, shell=True,
stdout=subprocess.PIPE, stdout=subprocess.PIPE,
encoding="utf-8") encoding="utf-8")
out, _ = s.communicate() out, _ = s.communicate()
if out != "": if out != "":
if t:
t.write(out) t.write(out)
else: else:
subprocess.Popen(self.task, shell=True) print(out)
class Worker(object): class Worker(object):
def __init__(self, task_queue, timeout, output, tqdm): def __init__(self, task_queue, timeout, output, tq):
self.queue = task_queue self.queue = task_queue
self.timeout = timeout self.timeout = timeout
self.output = output self.output = output
self.tqdm = tqdm self.tqdm = tq
def __call__(self): def __call__(self):
queue = self.queue queue = self.queue