(_, q=self._work_queue)
| 224 | # When the executor gets lost, the weakref callback will wake up |
| 225 | # the worker threads. |
| 226 | def weakref_cb(_, q=self._work_queue): |
| 227 | q.put(None) |
| 228 | |
| 229 | num_threads = len(self._threads) |
| 230 | if num_threads < self._max_workers: |