Tkinter异步GUI构建时API数据获取未执行问题排查

问题场景 #

通过异步main()函数启动Tkinter GUI，期望GUI构建的同时调用fetch_data从API获取数据，但GUI加载完成后fetch_data并未执行。

相关代码 #

主文件代码：

from concurrent.futures import ThreadPoolExecutor
import tkinter as tk
from fetch_data import fetch_data
from Filters import DataFilter
import json
import asyncio
from tkinter import filedialog
from FileProcessor import FileProcessor
from PIL import Image, ImageTk

async def main():
    root = tk.Tk()
    root.title("Assets report")
    submit_button = tk.Button(root, text="Generate the Report", state=tk.DISABLED, command=save_selected_dates, bg = "white")
    
    # gui setting here......

    def check_mana_status(root, data_future, submit_button):
        if data_future.done():
            submit_button["state"] = tk.NORMAL
        else:
            root.after(100, lambda: check_mana_status(root, data_future, submit_button))


    loop = asyncio.get_event_loop()
    with ThreadPoolExecutor() as executor:
        data_future = loop.run_in_executor(executor, fetch_data)

    check_mana_status(root, data_future, submit_button)

    root.mainloop()

asyncio.run(main())

fetch_data文件代码：

from FileProcessor import FileProcessor
from Filters import DataFilter
import requests
import asyncio
import aiohttp

async def fetch_data():
    url_exp = "https://example.url"
    try:
        print('start calls')
        results = await asyncio.gather(
            get_data(url_exp, headers),
            get_data(url_exp, headers),
            get_data(url_exp, headers),
            get_data(url_exp, headers)
            )

        response_data_co, response_data_ci, response_data_cr, response_data_hw = results

        print('ready')

    except requests.exceptions.RequestException as e:
        print("Error:", e)

    return [response_data_co + response_data_cr + response_data_ci, response_data_hw]

原因分析 #

1. 异步协程未被执行：fetch_data是异步函数，直接通过loop.run_in_executor(executor, fetch_data)提交到线程池，仅将协程对象传入线程，但未在该线程内启动asyncio事件循环调度协程，导致协程从未运行。
2. Tkinter主循环阻塞特性：root.mainloop()是阻塞调用，会占据主线程，即便协程被正确提交，asyncio事件循环也无法在主线程中调度任务（不过核心问题还是协程未被启动）。

解决方案 #

方案1：在子线程中启动asyncio事件循环

修改主文件中提交任务的代码，在线程内通过asyncio.run()启动协程：

# 替换原ThreadPoolExecutor代码块
with ThreadPoolExecutor() as executor:
    # 在线程内启动事件循环执行fetch_data协程
    data_future = loop.run_in_executor(executor, lambda: asyncio.run(fetch_data()))

方案2：用asyncio任务调度+Tkinter非阻塞更新

无需ThreadPoolExecutor，直接在async main中创建任务，通过after实现Tkinter与asyncio事件循环共存：

async def main():
    root = tk.Tk()
    root.title("Assets report")
    submit_button = tk.Button(root, text="Generate the Report", state=tk.DISABLED, command=save_selected_dates, bg = "white")
    
    # gui setting here......

    # 创建fetch_data异步任务
    data_task = asyncio.create_task(fetch_data())

    async def check_data_status():
        if data_task.done():
            submit_button["state"] = tk.NORMAL
        else:
            # 100ms后再次检查，同时让出事件循环
            root.after(100, lambda: asyncio.create_task(check_data_status()))

    # 启动状态检查任务
    asyncio.create_task(check_data_status())

    # 异步方式运行Tkinter主循环
    while True:
        root.update()
        await asyncio.sleep(0.01)

asyncio.run(main())

额外注意事项 #

• fetch_data中的get_data需为异步函数（基于aiohttp实现），若使用同步requests会阻塞线程，失去异步意义。示例可修改为：

async def get_data(url, headers):
    async with aiohttp.ClientSession() as session:
        async with session.get(url, headers=headers) as resp:
            return await resp.json()

• 确保fetch_data中已定义headers变量，否则会抛出NameError。

内容的提问来源于stack exchange，提问作者iGRiK