获取全局共享的事件循环
()
| 353 | |
| 354 | |
| 355 | def get_global_loop(): |
| 356 | """获取全局共享的事件循环""" |
| 357 | global _global_loop, _loop_thread |
| 358 | |
| 359 | with _loop_lock: |
| 360 | if _global_loop is None: |
| 361 | _global_loop = asyncio.new_event_loop() |
| 362 | |
| 363 | def run_forever(): |
| 364 | asyncio.set_event_loop(_global_loop) |
| 365 | _global_loop.run_forever() |
| 366 | |
| 367 | _loop_thread = threading.Thread(target=run_forever, daemon=True, name="GlobalAsyncLoop") |
| 368 | _loop_thread.start() |
| 369 | |
| 370 | return _global_loop |
| 371 | |
| 372 | |
| 373 | def _extract_tool_id(raw_id): |
no test coverage detected