(self)
| 2213 | self._finalizer = weakref.finalize(self, finalize, threads) |
| 2214 | |
| 2215 | def task(self): |
| 2216 | pid = os.getpid() |
| 2217 | self.started.append(pid) |
| 2218 | try: |
| 2219 | self.f(*self.args) |
| 2220 | finally: |
| 2221 | self.finished.append(pid) |
| 2222 | self._can_exit.wait(30) |
| 2223 | assert self._can_exit.is_set() |
| 2224 | |
| 2225 | def wait_for_started(self): |
| 2226 | while len(self.started) < self.n: |