(self)
| 277 | f'pool_size={len(self._pool)}>') |
| 278 | |
| 279 | def _get_sentinels(self): |
| 280 | task_queue_sentinels = [self._outqueue._reader] |
| 281 | self_notifier_sentinels = [self._change_notifier._reader] |
| 282 | return [*task_queue_sentinels, *self_notifier_sentinels] |
| 283 | |
| 284 | @staticmethod |
| 285 | def _get_worker_sentinels(workers): |