(self)
| 26 | if self.accept: |
| 27 | self.jobs.put((job, args, kw, callback)) |
| 28 | def join(self): |
| 29 | self.accept=False |
| 30 | while True: |
| 31 | for w in self.workers: |
| 32 | if w.isAlive() : |
| 33 | self.jobs.put((None, None, None, None)) |
| 34 | break |
| 35 | else: |
| 36 | break |
| 37 | @property |
| 38 | def qsize(self): return self.jobs.qsize() |
| 39 |