PyQt GUI结合NI设备持续数据采集程序崩溃问题求助

首先，咱们来拆解下你遇到的核心问题：当你用原生threading启动采集线程后，demarrer函数执行完DAQmxStartTask就立刻结束了，线程随之退出，这会导致NI的采集任务失去必要的上下文支撑，进而引发程序崩溃。而raw_input或者轮询循环的作用，其实是强行让线程保持存活状态，不让它马上退出，所以采集能正常运行，但这确实不是优雅的实现方式。

下面给你几个更合理的解决方案：

方案1：用PyQt的QThread替代原生threading模块 #

PyQt的QThread是专门为GUI线程交互设计的，能更好地和Qt的事件循环配合，还可以通过信号槽机制安全地和GUI通信，从根源上避免线程安全问题。

重构采集类为QThread子类 #

from PyQt4 import QtCore, QtGui
import nidaq

class IntensimetreThread(QtCore.QThread):
    # 定义信号，用来把采集到的数据传递给GUI
    data_received = QtCore.pyqtSignal(list)

    def __init__(self, app=None, l1=None, l2=None, l3=None, parent=None):
        super(IntensimetreThread, self).__init__(parent)
        self.app = app
        self.l1 = l1
        self.l2 = l2
        self.l3 = l3
        self._is_running = False
        self.task = None  # 保存NI任务句柄，方便后续管理

    def set_config(self, fs=51200., sensibilite0=12.2, sensibilite1=10.7, rho=1.21, espaceur=0.012, c=343):
        # 在这里完成采集参数配置、NI任务创建与通道初始化
        self.fs = fs
        self.sensibilite0 = sensibilite0
        # 示例：创建NI任务
        # self.task = nidaq.DAQmxCreateTask("采集任务")
        # 配置输入通道等操作...

    def run(self):
        self._is_running = True
        try:
            nidaq.DAQmxStartTask(self.task)
            while self._is_running:
                # 读取采集到的数据（根据你的NI设备API调整）
                # data = nidaq.DAQmxReadAnalogF64(...)
                # 通过信号把数据发送给GUI
                # self.data_received.emit(data)
                QtCore.QThread.msleep(10)  # 短暂休眠，避免占用过多CPU
        except Exception as e:
            print(f"采集过程出错: {e}")
        finally:
            # 无论是否出错，都要确保停止并清理NI任务
            nidaq.DAQmxStopTask(self.task)
            nidaq.DAQmxClearTask(self.task)
            self._is_running = False

    def stop(self):
        self._is_running = False
        self.wait()  # 等待线程安全退出

在GUI中使用这个线程 #

class GUI_acquisition(QtGui.QWidget):
    def __init__(self, app=None):
        super(GUI_acquisition, self).__init__()
        # 初始化GUI控件（按钮、显示区域等）...
        self.intensimetre_thread = IntensimetreThread(app=self.app, l1=self.l1, l2=self.l2, l3=self.l3)
        # 连接信号与槽，实现数据更新UI
        self.intensimetre_thread.data_received.connect(self.update_data_display)

    def demarrer(self):
        # 先配置采集参数
        self.intensimetre_thread.set_config(fs=51200., sensibilite0=12.2)
        # 启动采集线程
        self.intensimetre_thread.start()

    def arreter(self):
        # 停止采集线程
        self.intensimetre_thread.stop()

    def update_data_display(self, data):
        # 在这里更新GUI显示（比如图表、文本框），此方法运行在GUI主线程，安全可靠
        pass

方案2：保留原生threading，但优化线程生命周期管理 #

如果你不想改用QThread，也可以调整现有代码，确保采集线程持续运行直到用户触发停止，同时正确清理NI资源：

修改intensimetre类 #

import threading
import time
import nidaq

class intensimetre():
    def __init__(self, app=None, l1=None, l2=None, l3=None):
        self.app = app
        self.l1 = l1
        self.l2 = l2
        self.l3 = l3
        self._is_running = False
        self.task = None

    def demarrer(self, fs=51200., sensibilite0=12.2, sensibilite1=10.7, rho=1.21, espaceur=0.012, c=343):
        # 先完成NI任务的创建与参数配置
        # self.task = nidaq.DAQmxCreateTask(...)
        # 配置通道等操作...
        self._is_running = True
        nidaq.DAQmxStartTask(self.task)
        while self._is_running:
            # 读取采集数据（如果需要传递给GUI，可以用线程安全的队列）
            # data = nidaq.DAQmxReadAnalogF64(...)
            time.sleep(0.01)  # 缩短休眠时间，平衡CPU占用与实时性
        # 循环结束后必须清理NI任务
        nidaq.DAQmxStopTask(self.task)
        nidaq.DAQmxClearTask(self.task)

    def arreter(self):
        self._is_running = False

在GUI中调整调用方式 #

class GUI_acquisition(QtGui.QWidget):
    def __init__(self, app=None):
        super(GUI_acquisition, self).__init__()
        # 初始化GUI控件...
        self.intensimetre = intensimetre(app=self.app, l1=self.l1, l2=self.l2, l3=self.l3)
        self.acquisition_thread = None

    def demarrer(self):
        # 避免重复启动线程
        if self.acquisition_thread is None or not self.acquisition_thread.is_alive():
            self.acquisition_thread = threading.Thread(target=self.intensimetre.demarrer)
            self.acquisition_thread.start()

    def arreter(self):
        self.intensimetre.arreter()
        if self.acquisition_thread is not None:
            self.acquisition_thread.join()  # 等待线程安全退出

关键注意点 #

• NI任务的生命周期：无论哪种方案，都必须在采集结束后调用DAQmxStopTask和DAQmxClearTask，避免资源泄漏。
• 线程安全更新GUI：如果要在采集线程中更新GUI，必须用PyQt的信号槽机制（QThread方案），或者QMetaObject.invokeMethod，绝对不能直接在非GUI线程操作GUI控件。
• CPU占用优化：循环中的休眠时间不用太长，0.01秒就足够，既能减少CPU占用，又不会影响实时采集的精度。

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