Python BLE消息接收应用等待时无响应问题排查求助

核心原因：UI线程被阻塞 #

你的应用基于tkinter开发，而tkinter是单线程事件驱动框架。在receiveMSG函数中，select.select([client_sock], [], [], 1)会阻塞UI线程整整1秒——这期间tkinter无法处理按钮点击、界面刷新等用户交互，所以看起来像是“冻结”。只有当select超时结束或收到消息触发后续UI更新时，界面才会恢复响应。

另外，startBT里的server_sock.accept()也是阻塞调用，如果蓝牙连接未建立，整个UI线程会一直卡在这一步，直到有设备连接。

具体问题点 #

1. 阻塞操作放在UI线程：select.select和潜在的recv操作都在主线程执行，打断了tkinter的事件循环。
2. 消息处理不规范：用字符串替换处理bytes转字符串（message.replace("b", "").replace("'", "")）容易出错，应该用data.decode('utf-8')直接解码。
3. 全局变量使用不严谨：用字符串"true"表示连接状态，不如布尔值清晰，且没有线程安全保护（后续用线程时会有问题）。

修复方案 #

1. 将蓝牙接收逻辑移到独立线程 #

把连接建立、消息接收放到单独线程，避免阻塞UI线程：

import threading

def startBT():
    server_sock = BluetoothSocket(RFCOMM)
    server_sock.bind(("", PORT_ANY))
    server_sock.listen(1)

    port = server_sock.getsockname()[1]
    uuid = "a8d52687-55bb-4b1b-b8f5-a1b17cdb0e59"

    advertise_service(server_sock, "SampleServer",
                    service_id=uuid,
                    service_classes=[uuid, SERIAL_PORT_CLASS],
                    profiles=[SERIAL_PORT_PROFILE])
                
    print("Waiting for connection on RFCOMM channel %d" % port)

    global client_sock, isConnected
    client_sock, client_info = server_sock.accept()
    isConnected = True  # 改用布尔值
    print("Accepted connection from ", client_info)
    
    # 启动独立线程处理消息接收
    threading.Thread(target=receiveMSG, daemon=True).start()
    loadData()

2. 重构消息接收函数，线程安全更新UI #

在子线程中处理蓝牙消息，通过root.after将UI更新操作抛回主线程：

def receiveMSG():
    while isConnected:
        try:
            # 缩短select超时时间，减少线程阻塞时长
            ready = select.select([client_sock], [], [], 0.1)
            if ready[0]:
                data = client_sock.recv(1024)
                if not data:  # 检测到连接断开
                    isConnected = False
                    break
                # 规范解码bytes为字符串
                message = data.decode('utf-8').strip()
                print(message)
                
                # 用after将UI更新操作放到主线程执行
                if "Stop" in message:
                    kart_num = message.replace("Stop", "")
                    root.after(0, lambda: update_log(f"Kart #{kart_num} has been stopped.\n"))
                elif "Res" in message:
                    kart_num = message.replace("Res", "")
                    root.after(0, lambda: update_log(f"Kart #{kart_num} has been resumed.\n"))
                elif "Pen" in message:
                    messagelist = message.split()
                    if len(messagelist) >=2:
                        kart_num = messagelist[0].replace("Pen", "")
                        penalty = messagelist[1]
                        root.after(0, lambda: update_log(f"Kart #{kart_num} has been given a penalty of {penalty} seconds.\n"))
        except Exception as e:
            print(f"接收消息出错: {e}")
            isConnected = False
            break

# 单独的日志更新函数，确保在主线程执行
def update_log(content):
    GLineEdit_692["state"] = "normal"
    GLineEdit_692.insert(tk.END, content)
    GLineEdit_692["state"] = "disabled"

3. 额外优化建议 #

• 给isConnected加锁：因为多线程读写全局变量，建议用threading.Lock保证线程安全。
• 处理连接断开的情况：在receiveMSG中捕获异常，及时设置isConnected=False，避免线程死循环。
• 移除原receiveMSG中的root.after：因为现在用独立线程循环，不需要靠after调度。

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