Python多文件实时数据传递问题：无法获取车道更新数据

问题核心 #

多线程环境下，GUI线程与模拟线程的共享数据（lane1等车道数组）未做线程安全同步，且GUI未主动感知数据更新，导致仅能读取初始空值。

1. 线程安全共享状态改造（sharedState.py） #

将车道数据统一移至共享状态类，用锁保护读写操作，避免多线程竞争：

import threading

class LaneState:
    def __init__(self):
        self.lanes = {
            "lane1": [],
            "lane2": []
            # 按需添加其他车道
        }
        self.lock = threading.Lock()
        self.update_callbacks = []

    def update_lane(self, lane_name, customer_list):
        """线程安全更新车道数据"""
        with self.lock:
            self.lanes[lane_name] = customer_list.copy()
            # 触发所有注册的更新回调
            for callback in self.update_callbacks:
                callback(lane_name, self.lanes[lane_name])

    def get_lane(self, lane_name):
        """线程安全读取车道数据"""
        with self.lock:
            return self.lanes[lane_name].copy()

    def register_update_callback(self, callback):
        """注册数据更新后的回调函数"""
        with self.lock:
            self.update_callbacks.append(callback)

# 全局共享实例，所有线程共用
shared_lane_state = LaneState()

2. 模拟线程适配（visual.py/main.py） #

修改模拟逻辑，通过共享状态类更新车道数据，而非直接操作数组：

from sharedState import shared_lane_state

# 示例：客户进入车道时更新数据
def add_customer_to_lane(lane_name, customer):
    # 获取当前车道数据并修改
    current_lane = shared_lane_state.get_lane(lane_name)
    current_lane.append(customer)
    # 提交更新
    shared_lane_state.update_lane(lane_name, current_lane)

3. GUI线程实时数据获取（GUILogtask1f1.py） #

方式一：主动轮询（简单直接） #

在按钮点击或定时任务中主动拉取最新数据：

import tkinter as tk
from sharedState import shared_lane_state

def print_value():
    """按钮点击时获取实时车道数据"""
    current_lane1 = shared_lane_state.get_lane("lane1")
    print(f"Lane1 当前状态: {current_lane1}")
    # 更新GUI显示
    lane1_label.config(text=f"Lane1: {current_lane1}")

def auto_refresh():
    """定时自动刷新GUI（每1秒一次）"""
    current_lane1 = shared_lane_state.get_lane("lane1")
    lane1_label.config(text=f"Lane1: {current_lane1}")
    root.after(1000, auto_refresh)

# GUI初始化
root = tk.Tk()
lane1_label = tk.Label(root, text="Lane1: []")
lane1_label.pack(pady=10)
query_btn = tk.Button(root, text="查看车道状态", command=print_value)
query_btn.pack()

# 启动自动刷新
auto_refresh()

root.mainloop()

方式二：回调通知（实时性更强） #

注册回调函数，模拟线程更新数据后主动通知GUI刷新：

import tkinter as tk
from sharedState import shared_lane_state

def on_lane_update(lane_name, data):
    """数据更新时的回调，确保UI操作在主线程执行"""
    def update_ui():
        if lane_name == "lane1":
            lane1_label.config(text=f"Lane1: {data}")
    root.after(0, update_ui)  # 将UI操作抛回GUI主线程

# GUI初始化
root = tk.Tk()
lane1_label = tk.Label(root, text="Lane1: []")
lane1_label.pack(pady=10)

# 注册更新回调
shared_lane_state.register_update_callback(on_lane_update)

root.mainloop()

关键注意事项 #

• 所有共享数据的读写必须通过Lock保护，避免数据竞争导致的不一致。
• tkinter要求所有UI操作必须在主GUI线程执行，因此回调中的UI更新需用root.after()转至主线程。

内容的提问来源于stack exchange，提问作者Md Mahfuz Anam Tasnim