(self, _warn=warnings.warn)
| 908 | self._threads = {} |
| 909 | |
| 910 | def __del__(self, _warn=warnings.warn): |
| 911 | threads = [thread for thread in list(self._threads.values()) |
| 912 | if thread.is_alive()] |
| 913 | if threads: |
| 914 | _warn(f"{self.__class__} has registered but not finished child processes", |
| 915 | ResourceWarning, |
| 916 | source=self) |
| 917 | |
| 918 | def add_child_handler(self, pid, callback, *args): |
| 919 | loop = events.get_running_loop() |