aljaz/Interlace
1
1
Fork 0
mirror of https://github.com/codingo/Interlace.git synced 2026-01-24 17:34:46 +01:00
Code Issues Packages Projects Releases Wiki Activity

[BUGFIX] Thread invokation

Browse Source
This commit is contained in:
Michael Skelton
2018-10-23 22:50:02 +10:00
parent 053853c53d
commit 10a6d9f1d7
1 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
Interlace/lib/core/threader.py
View File

@@ -3,22 +3,20 @@ import subprocess
class Worker(object):
def __init__(self, pool, output, timeout):
def __init__(self, pool):
self.pool = pool
self.output = output
self.timeout = timeout
def __call__(self, task):
self.run_task(task, self.timeout)
self.run_task(task)
self.pool.workers.add(self)
def run_task(self, task, timeout):
def run_task(self, task):
try:
subprocess.run(task)
except subprocess.TimeoutExpired:
self.output.terminal(3, "", task, message="Timeout when running %s" % task)
self.pool.output.terminal(3, "", task, message="Timeout when running %s" % task)
except subprocess.CalledProcessError:
self.output.terminal(3, "", task, message="Process error when running %s"
self.pool.output.terminal(3, "", task, message="Process error when running %s"
% task)
@@ -43,5 +41,5 @@ class Pool(object):
task = self.queue.pop(0)
# run
thread = threading.Thread(worker, args=(task, self.output, self.timeout))
thread = threading.Thread(target=worker, args=(task, self.output, self.timeout))
thread.start()