fix: create a new Python thread to avoid blocking extension thread

core/src/ten_runtime/binding/python/interface/ten/async_ten_env.py

@@ -19,7 +19,8 @@ def __init__(
     ) -> None:
         self._internal = ten_env._internal
         self._ten_loop = loop
-        ten_env._set_release_handler(lambda: thread.join())
+        self._ten_thread = thread
+        ten_env._set_release_handler(lambda: self._on_release())
 
     def __del__(self) -> None:
         pass
@@ -43,3 +44,15 @@ async def send_json(self, json_str: str) -> CmdResult:
             ),  # type: ignore
         )
         return await q.get()
+
+    def _deinit_routine(self) -> None:
+        self._ten_thread.join()
+        self._internal.on_deinit_done()
+
+    def _on_release(self) -> None:
+        if hasattr(self, "_deinit_thread"):
+            self._deinit_thread.join()
+
+    def on_deinit_done(self) -> None:
+        self._deinit_thread = threading.Thread(target=self._deinit_routine)
+        self._deinit_thread.start()

tests/ten_runtime/integration/python/two_async_exts_one_group_python/two_async_exts_one_group_python_app/ten_packages/extension/default_extension_python/extension.py

@@ -34,6 +34,8 @@ async def on_deinit(self, ten_env: AsyncTenEnv) -> None:
         await asyncio.sleep(0.5)
         ten_env.on_deinit_done()
 
+        await asyncio.sleep(1)
+
     async def on_cmd(self, ten_env: AsyncTenEnv, cmd: Cmd) -> None:
         cmd_json = cmd.to_json()
         ten_env.log_debug(f"DefaultExtension on_cmd: {cmd_json}")

tests/ten_runtime/integration/python/two_async_exts_python/two_async_exts_python_app/ten_packages/extension/default_extension_python/extension.py

@@ -34,6 +34,8 @@ async def on_deinit(self, ten_env: AsyncTenEnv) -> None:
         await asyncio.sleep(0.5)
         ten_env.on_deinit_done()
 
+        await asyncio.sleep(1)
+
     async def on_cmd(self, ten_env: AsyncTenEnv, cmd: Cmd) -> None:
         cmd_json = cmd.to_json()
         ten_env.log_debug(f"DefaultExtension on_cmd: {cmd_json}")