(self, job, callback=None, *args, **kw)
| 23 | return len(self.workers) |
| 24 | return get, set |
| 25 | def add(self, job, callback=None, *args, **kw): |
| 26 | if self.accept: |
| 27 | self.jobs.put((job, args, kw, callback)) |
| 28 | def join(self): |
| 29 | self.accept=False |
| 30 | while True: |
no test coverage detected