equal
deleted
inserted
replaced
121 self.mutex.release() |
121 self.mutex.release() |
122 waker(job_todo) |
122 waker(job_todo) |
123 self.feed.wait() |
123 self.feed.wait() |
124 |
124 |
125 self.mutex.release() |
125 self.mutex.release() |
126 self.own_thread = Thread(target = wakerfeedingloop).start() |
126 self.own_thread = Thread(target = wakerfeedingloop) |
|
127 self.own_thread.start() |
127 |
128 |
128 def stop(): |
129 def stop(self): |
129 """ |
130 """ |
130 !interleave |
131 !interleave |
131 """ |
132 """ |
132 self.mutex.acquire() |
133 self.mutex.acquire() |
133 self._finish = True |
134 self._finish = True |