RPi4 Python环境下GYRO与BLE扫描线程冲突问题咨询

一、线程是否是正确的实现方式？ #

对于你这种包含I/O密集型任务的场景（MPU6050传感器读取、BLE设备通信），线程是完全合适的选择：

• 传感器读取、BLE通信都属于等待外部响应的I/O操作，这类操作会自动释放Python的GIL（全局解释器锁），不会阻塞其他线程运行；
• 线程比进程更轻量，上下文切换开销小，适合需要并行处理且资源开销敏感的树莓派项目。

你的问题并非线程本身的设计错误，而是两个模块之间存在底层资源冲突或asyncio与线程的交互问题。

二、冲突原因分析 #

bleak库抛出的Operation already in progress异常，核心原因是同一蓝牙适配器被多个操作同时占用。结合你的测试结果（先启动GYRO再启动SCAN才会报错），大概率是：

1. GYRO线程运行时，意外占用了蓝牙适配器相关的系统资源（比如某些底层驱动资源）；
2. asyncio的事件循环与GYRO线程的运行状态存在冲突——比如SCAN的asyncio代码依赖主线程的事件循环，而GYRO线程的运行干扰了主线程事件循环的状态；
3. 两个模块共享了某个未加锁的全局资源，导致并发访问时冲突。

三、具体解决方案 #

1. 给蓝牙操作加互斥锁 #

如果SCAN的BLE操作和GYRO线程存在间接的资源共享（比如系统蓝牙驱动），可以用threading.Lock()确保同一时间只有一个操作访问蓝牙资源：

import threading

# 全局互斥锁
ble_lock = threading.Lock()

def gyro_thread_function(arg):
    while True:
        # 读取MPU6050数据
        ...
        # 如果GYRO中有涉及蓝牙的操作（哪怕是间接的），加锁
        with ble_lock:
            # 相关操作
            ...
        time.sleep(2)

def scan_thread_function(arg):
    with ble_lock:
        # 启动asyncio的BLE扫描逻辑
        loop = asyncio.new_event_loop()
        asyncio.set_event_loop(loop)
        loop.run_until_complete(ble_scan_task())
        loop.close()

2. 为SCAN创建独立的asyncio事件循环 #

由于SCAN基于asyncio，而GYRO是线程，默认情况下asyncio依赖主线程的事件循环，可能被GYRO线程干扰。可以在SCAN的线程中创建独立的事件循环，避免冲突：

import asyncio

def scan_thread_function(arg):
    # 创建独立的事件循环
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    # 运行BLE扫描的异步任务
    loop.run_until_complete(scan_and_connect_ble())
    loop.close()

3. 检查并隔离GYRO的资源占用 #

确认GYRO线程是否意外占用了蓝牙相关资源：

• 检查MPU6050的驱动代码，是否误操作了蓝牙适配器（比如树莓派的I2C与蓝牙引脚是否重叠？可以通过raspi-config确认引脚配置）；
• 给GYRO线程设置停止标志，在启动SCAN前临时暂停GYRO线程，验证是否还会报错：

stop_gyro = False

def gyro_thread_function(arg):
    global stop_gyro
    while not stop_gyro:
        # 读取MPU6050数据并写入
        ...
        time.sleep(2)

# 启动SCAN前的操作
stop_gyro = True
gyro_thread.join()  # 等待GYRO线程退出
# 启动SCAN
scan_thread = threading.Thread(target=scan_thread_function, args=(1,))
scan_thread.start()
# SCAN结束后恢复GYRO
stop_gyro = False
gyro_thread = threading.Thread(target=gyro_thread_function, args=(1,))
gyro_thread.start()

4. 用进程替代线程（终极方案） #

如果线程级的资源隔离无法解决冲突，可以用multiprocessing.Process代替线程——进程之间拥有完全独立的资源空间，不会共享底层驱动或全局状态：

from multiprocessing import Process

# 启动GYRO进程
gyro_proc = Process(target=gyro_thread_function, args=(1,))
gyro_proc.start()

# 启动SCAN进程
scan_proc = Process(target=scan_thread_function, args=(1,))
scan_proc.start()

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