(self)
| 2009 | self._finalizer = weakref.finalize(self, finalize, threads) |
| 2010 | |
| 2011 | def task(self): |
| 2012 | pid = os.getpid() |
| 2013 | self.started.append(pid) |
| 2014 | try: |
| 2015 | self.f(*self.args) |
| 2016 | finally: |
| 2017 | self.finished.append(pid) |
| 2018 | self._can_exit.wait(30) |
| 2019 | assert self._can_exit.is_set() |
| 2020 | |
| 2021 | def wait_for_started(self): |
| 2022 | while len(self.started) < self.n: |