关闭当前Session。由Backend调用
(self, nonblock=False)
| 212 | self.task_mqs = {} |
| 213 | |
| 214 | def close(self, nonblock=False): |
| 215 | """关闭当前Session。由Backend调用""" |
| 216 | # todo self._closed 会有竞争条件 |
| 217 | if self.closed(): |
| 218 | return |
| 219 | |
| 220 | super().close() |
| 221 | |
| 222 | self._cleanup(nonblock=nonblock) |
| 223 | |
| 224 | def _activate_callback_env(self): |
| 225 | """激活回调功能 |