Job.py (SCons-4.3.0) | : | Job.py (SCons-4.4.0) | ||
---|---|---|---|---|
skipping to change at line 238 | skipping to change at line 238 | |||
import threading | import threading | |||
except ImportError: | except ImportError: | |||
pass | pass | |||
else: | else: | |||
class Worker(threading.Thread): | class Worker(threading.Thread): | |||
"""A worker thread waits on a task to be posted to its request queue, | """A worker thread waits on a task to be posted to its request queue, | |||
dequeues the task, executes it, and posts a tuple including the task | dequeues the task, executes it, and posts a tuple including the task | |||
and a boolean indicating whether the task executed successfully. """ | and a boolean indicating whether the task executed successfully. """ | |||
def __init__(self, requestQueue, resultsQueue, interrupted): | def __init__(self, requestQueue, resultsQueue, interrupted): | |||
threading.Thread.__init__(self) | super().__init__() | |||
self.daemon = True | self.daemon = True | |||
self.requestQueue = requestQueue | self.requestQueue = requestQueue | |||
self.resultsQueue = resultsQueue | self.resultsQueue = resultsQueue | |||
self.interrupted = interrupted | self.interrupted = interrupted | |||
self.start() | self.start() | |||
def run(self): | def run(self): | |||
while True: | while True: | |||
task = self.requestQueue.get() | task = self.requestQueue.get() | |||
End of changes. 1 change blocks. | ||||
1 lines changed or deleted | 1 lines changed or added |