(self)
| 151 | self.start() |
| 152 | |
| 153 | def run (self): |
| 154 | self.result = self.func(self) |
| 155 | self.done = True |
| 156 | if self.connections["done"] >= 1: |
| 157 | threads_enter() |
| 158 | # In python 2.5 we can use self.publishQueue.join() to wait for all |
| 159 | # publish items to have been processed. |
| 160 | self.emit("done") |
| 161 | threads_leave() |
| 162 | |
| 163 | def cancel (self): |
| 164 | """ Cancel work. |