Connecting Asyncio and Tkinter event loops?

congzhangzh · March 17, 2025, 5:15pm

Hi folks,

I do a complete prototype of guest mode, which should work for all UI framework

Hope some guys can do a review, can you give some help @guido
this 120 line of code will make asyncio easy to integrate to any GUI framework:)

asyncio guest mode:

github.com/congzhangzh/asyncio_guest_run

v2/asyncio_guest_run.py

main

import asyncio
import threading

def is_debug():
    return False  # 简化调试输出

def asyncio_guest_run(async_func, *async_func_args, run_sync_soon_threadsafe, run_sync_soon_not_threadsafe, done_callback):
    """最简化的asyncio guest运行函数"""
    # 创建信号量用于线程协调
    sem = threading.Semaphore(0)
    
    # 创建事件循环
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    asyncio._set_running_loop(loop)

    # 修补loop._check_running方法
    # original_check_running = loop._check_running
    # def patched_check_running(self):
    #     # 忽略运行状态检查

This file has been truncated. show original

patch for base_events.py

github.com/congzhangzh/asyncio_guest_run

v2/patches/base_events.diff

main

--- base_events_original.py	2024-10-07 10:26:48.000000000 +0800
+++ base_events_patched.py	2025-03-18 01:00:23.045485200 +0800
@@ -2050,3 +2050,48 @@
 
         if self.is_running():
             self.call_soon_threadsafe(self._set_coroutine_origin_tracking, enabled)
+
+    def poll_events(self):
+        """轮询I/O事件但不处理它们"""
+        # 计算超时时间 - 保留动态超时计算
+        timeout = None
+        if self._ready or self._stopping:
+            timeout = 0
+        elif self._scheduled:
+            # 计算所需的超时时间
+            timeout = self._scheduled[0]._when - self.time()
+            if timeout > MAXIMUM_SELECT_TIMEOUT:
+                timeout = MAXIMUM_SELECT_TIMEOUT
+            elif timeout < 0:
+                timeout = 0

This file has been truncated. show original

baseline: asyncio_guest_run/v2/patches/base_events_original_notes.md at main · congzhangzh/asyncio_guest_run · GitHub

sample

github.com/congzhangzh/asyncio_guest_run

v2/asyncio_guest_win32_with_load_hook.py

4e88da512


      
                  # hack around uint16 issue
                  self.realmax = maximum
                  self.dialog.pbar.SetRange(0, 65535)
          
              def set_value(self, downloaded):
                  self.dialog.pbar.SetPos(int((downloaded / self.realmax * 65535)))
          
              def set_cancel(self, fn):
                  self.dialog.cancelfn = fn
          
          def main(task):
              display = Win32Display()
              host = Win32Host(display)
              #trio.lowlevel.start_guest_run
              asyncio_guest_run.asyncio_guest_run(
                  task,
                  display,
                  run_sync_soon_threadsafe=host.run_sync_soon_threadsafe,
                  run_sync_soon_not_threadsafe=host.run_sync_soon_not_threadsafe,
                  done_callback=host.done_callback,
              )

Tks,
Cong