注册一个需要清理的资源(如HTTP客户端、文件句柄等)
(self, resource: Any)
| 49 | return self.register_task(task, name) |
| 50 | |
| 51 | def register_resource(self, resource: Any) -> Any: |
| 52 | """注册一个需要清理的资源(如HTTP客户端、文件句柄等)""" |
| 53 | # 使用弱引用避免循环引用 |
| 54 | self._resources.add(weakref.ref(resource)) |
| 55 | log.debug(f"Registered resource: {type(resource).__name__}") |
| 56 | return resource |
| 57 | |
| 58 | async def shutdown(self, timeout: float = 30.0): |
| 59 | """关闭所有任务和资源""" |
no test coverage detected