Python Raspberry Pi水培系统线程控制逻辑故障排查求助

核心逻辑问题 #

• 共享资源竞争：继电器GPIO、LCD显示屏属于多线程共享资源，未做同步控制时，多个线程同时操作会导致：继电器被频繁触发启停（多个线程同时修改引脚状态）；LCD显示混乱/乱码（多个线程同时写入屏幕）。
• 缺乏优雅退出机制：没有统一的信号通知所有线程停止，直接终止会导致GPIO未重置、LCD未清理等资源泄漏问题。
• 线程职责不清晰：设备线程和传感器显示线程可能存在交叉操作共享资源的情况，比如设备线程同时修改LCD、传感器线程操作GPIO，进一步加剧竞争。

具体修复措施 #

1. 给共享资源加线程锁 #

使用threading.Lock()对所有共享资源的操作加锁，确保同一时间只有一个线程能访问：

• 对LCD的所有写入/清除操作加锁，避免多线程同时刷新屏幕。
• 对继电器GPIO的引脚状态修改加锁，防止多个线程同时触发同一设备的继电器。

2. 用threading.Event()实现优雅停止 #

创建全局的停止事件，所有线程在循环中定期检查该事件：

• 双按键触发时，设置stop_event.set()，通知所有线程准备退出。
• 每个设备线程、传感器显示线程在循环开头/关键节点检查stop_event.is_set()，如果为True则退出循环，执行资源清理（比如重置GPIO、清除LCD）。

3. 明确线程职责 #

• 设备线程：仅负责对应设备的控制逻辑（如雾化器的启停判断），只操作自身对应的GPIO引脚，不触碰LCD等其他资源。
• LCD显示线程：单独一个线程负责传感器数据的周期轮换显示，该线程持有LCD锁，按固定周期切换显示内容，其他线程仅提供传感器数据，不直接操作LCD。

4. 优化按键检测逻辑 #

双按键检测单独用一个线程实现，避免阻塞其他线程，检测到双按键同时按下时立即触发停止事件。

修复代码示例片段 #

import threading
import RPi.GPIO as GPIO
import time

# 全局控制变量
stop_event = threading.Event()
lcd_lock = threading.Lock()
gpio_lock = threading.Lock()

# 设备引脚定义（示例）
MIST_PIN = 17
HEAT_LAMP_PIN = 18
OXYGEN_PIN = 27
KEY1_PIN = 22
KEY2_PIN = 23

def mist_control_thread():
    while not stop_event.is_set():
        # 模拟雾化器控制逻辑（如检测湿度后启停）
        with gpio_lock:
            GPIO.output(MIST_PIN, GPIO.HIGH)
        time.sleep(5)
        with gpio_lock:
            GPIO.output(MIST_PIN, GPIO.LOW)
        time.sleep(30)
    # 退出前重置引脚
    with gpio_lock:
        GPIO.output(MIST_PIN, GPIO.LOW)

def heat_lamp_control_thread():
    while not stop_event.is_set():
        # 模拟加热灯控制逻辑（如检测温度后启停）
        with gpio_lock:
            GPIO.output(HEAT_LAMP_PIN, GPIO.HIGH)
        time.sleep(10)
        with gpio_lock:
            GPIO.output(HEAT_LAMP_PIN, GPIO.LOW)
        time.sleep(20)
    with gpio_lock:
        GPIO.output(HEAT_LAMP_PIN, GPIO.LOW)

def oxygen_control_thread():
    while not stop_event.is_set():
        # 模拟制氧机控制逻辑
        with gpio_lock:
            GPIO.output(OXYGEN_PIN, GPIO.HIGH)
        time.sleep(15)
        with gpio_lock:
            GPIO.output(OXYGEN_PIN, GPIO.LOW)
        time.sleep(15)
    with gpio_lock:
        GPIO.output(OXYGEN_PIN, GPIO.LOW)

def sensor_lcd_thread(sensor_getters):
    """传感器数据轮换显示线程"""
    while not stop_event.is_set():
        for sensor_name, get_data in sensor_getters.items():
            if stop_event.is_set():
                break
            data = get_data()
            with lcd_lock:
                # 假设lcd是已初始化的LCD对象
                lcd.clear()
                lcd.message(f"{sensor_name}:\n{data}")
            time.sleep(5)
    with lcd_lock:
        lcd.clear()
        lcd.message("System Stopped")

def kill_switch_thread():
    while not stop_event.is_set():
        # 检测双按键是否同时按下（低电平触发示例）
        if GPIO.input(KEY1_PIN) == GPIO.LOW and GPIO.input(KEY2_PIN) == GPIO.LOW:
            stop_event.set()
            break
        time.sleep(0.1)

# 初始化GPIO
GPIO.setmode(GPIO.BCM)
for pin in [MIST_PIN, HEAT_LAMP_PIN, OXYGEN_PIN]:
    GPIO.setup(pin, GPIO.OUT)
    GPIO.output(pin, GPIO.LOW)
for pin in [KEY1_PIN, KEY2_PIN]:
    GPIO.setup(pin, GPIO.IN, pull_up_down=GPIO.PUD_UP)

# 模拟传感器数据获取函数
def get_ph_data():
    return "6.8"
def get_temp_data():
    return "25.3°C"
sensor_funcs = {"PH": get_ph_data, "Temp": get_temp_data}

# 启动所有线程
threads = [
    threading.Thread(target=mist_control_thread),
    threading.Thread(target=heat_lamp_control_thread),
    threading.Thread(target=oxygen_control_thread),
    threading.Thread(target=sensor_lcd_thread, args=(sensor_funcs,)),
    threading.Thread(target=kill_switch_thread)
]

for t in threads:
    t.start()

# 等待所有线程结束
for t in threads:
    t.join()

# 清理资源
GPIO.cleanup()

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