equal
deleted
inserted
replaced
71 # _job.success can't be None after do() |
71 # _job.success can't be None after do() |
72 if not _job.success: |
72 if not _job.success: |
73 self.reraise(_job) |
73 self.reraise(_job) |
74 |
74 |
75 while not self._finish: |
75 while not self._finish: |
76 self.todo.wait_for(self.job is not None) |
76 self.todo.wait_for(lambda: self.job is not None) |
77 self.job.do() |
77 self.job.do() |
78 self.done.notify() |
78 self.done.notify() |
79 |
79 |
80 self.mutex.release() |
80 self.mutex.release() |
81 |
81 |