如何保持串口持续打开并优化多窗体串口读取方案

我完全懂你现在的困扰——每次调用都开关串口，不仅浪费IO资源，多窗体调用还容易引发异常，每秒20次的调用频率更是雪上加霜。咱们来重构一下代码，改成后台持续读取串口+线程安全数据共享的模式，彻底解决效率问题。

核心思路 #

• 用一个后台线程专门负责串口的初始化、持续读取和数据解析，只打开/关闭串口一次，避免频繁IO操作
• 维护一个线程安全的共享变量存储最新解析后的数据，所有窗体/函数直接查询这个变量即可
• 用任务取消机制管理后台线程，确保程序退出时能正确释放串口资源

完整实现代码 #

using System;
using System.IO.Ports;
using System.Threading;
using System.Threading.Tasks;

class COMPortStream
{
    private static readonly string COM = Properties.Settings.Default.COMPort;
    private static SerialPort _forcePort;
    private static string[] _latestLoads;
    // 线程安全锁，避免多线程读写共享数据时出现混乱
    private static readonly object _dataLock = new object();
    private static CancellationTokenSource _cts;
    private static Task _readTask;

    // 静态构造函数：第一次访问类时自动初始化串口和后台读取任务
    static COMPortStream()
    {
        _forcePort = new SerialPort(COM, 19200, Parity.None, 8, StopBits.One);
        _forcePort.ReadTimeout = 500; // 设置合理的读取超时，防止线程卡死
        _cts = new CancellationTokenSource();
        // 启动后台读取任务
        _readTask = Task.Run(ContinuousReadLoop, _cts.Token);
    }

    // 后台持续读取串口的循环逻辑
    private static void ContinuousReadLoop()
    {
        try
        {
            if (!_forcePort.IsOpen)
            {
                _forcePort.Open();
                Console.WriteLine("串口已打开，开始持续读取数据");
            }

            while (!_cts.Token.IsCancellationRequested)
            {
                try
                {
                    // 保持你原来的读取逻辑（根据设备协议调整）
                    string buffer = _forcePort.ReadTo("\r");
                    string message = _forcePort.ReadTo("\r");
                    string[] arr = message.Split('N');

                    // 转换单位并更新共享数据（加锁确保线程安全）
                    lock (_dataLock)
                    {
                        for (int i = 0; i < Math.Min(2, arr.Length); i++)
                        {
                            if (double.TryParse(arr[i], out double nValue))
                            {
                                double lbf = N2P(nValue);
                                arr[i] = lbf.ToString("N1");
                            }
                            else
                            {
                                // 解析失败时设默认值，避免异常扩散
                                arr[i] = "0.0";
                            }
                        }
                        _latestLoads = arr;
                    }
                }
                catch (TimeoutException)
                {
                    // 读取超时是正常情况，不用关闭串口，继续循环即可
                    continue;
                }
                catch (Exception ex)
                {
                    Console.WriteLine($"读取串口出错: {ex.Message}");
                    // 出错后短暂休眠再重试，避免CPU空转
                    Thread.Sleep(100);
                }
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine($"串口初始化失败: {ex.Message}");
        }
        finally
        {
            // 任务取消时关闭串口
            if (_forcePort.IsOpen)
            {
                _forcePort.Close();
                Console.WriteLine("串口已关闭");
            }
        }
    }

    // 对外提供的获取最新数据的方法
    public static string[] GetLatestLoads()
    {
        lock (_dataLock)
        {
            // 返回数据副本，避免外部修改共享数组
            return _latestLoads?.Clone() as string[];
        }
    }

    // 单位转换方法保持不变
    private static double N2P(double N)
    {
        return N * 0.224809;
    }

    // 程序退出时调用，停止后台任务并关闭串口
    public static void Shutdown()
    {
        _cts.Cancel();
        try
        {
            _readTask.Wait(1000);
        }
        catch (AggregateException)
        {
            // 忽略任务取消的异常
        }
    }
}

关键改进点说明 #

• 避免频繁开关串口：串口只在程序启动时打开，退出时关闭，彻底消除重复IO的开销
• 线程安全数据共享：用lock保证多线程读写共享数据时的一致性，返回副本防止外部篡改原数据
• 异常处理优化：读取超时不中断流程，其他异常自动重试，提升稳定性
• 后台任务可控：用CancellationTokenSource管理后台线程，确保程序退出时能正确释放资源

窗体中调用示例 #

// 在窗体定时器或需要获取数据的地方调用
string[] latestLoads = COMPortStream.GetLatestLoads();
if (latestLoads != null && latestLoads.Length >= 2)
{
    // WinForms中跨线程更新控件需要用Invoke
    if (label1.InvokeRequired)
    {
        label1.Invoke(() => label1.Text = $"负载1: {latestLoads[0]} lbf");
        label2.Invoke(() => label2.Text = $"负载2: {latestLoads[1]} lbf");
    }
    else
    {
        label1.Text = $"负载1: {latestLoads[0]} lbf";
        label2.Text = $"负载2: {latestLoads[1]} lbf";
    }
}
else
{
    if (label1.InvokeRequired)
    {
        label1.Invoke(() => label1.Text = "暂无数据");
        label2.Invoke(() => label2.Text = "暂无数据");
    }
    else
    {
        label1.Text = "暂无数据";
        label2.Text = "暂无数据";
    }
}

// 主窗体关闭时调用Shutdown释放资源
private void MainForm_FormClosing(object sender, FormClosingEventArgs e)
{
    COMPortStream.Shutdown();
}

额外注意事项 #

• 确保串口参数（波特率、奇偶校验等）和设备协议完全匹配，如果设备换行符不是\r，需要调整ReadTo的参数
• 如果你的程序是WinForms，更新UI控件时必须用Invoke/BeginInvoke，避免跨线程操作异常
• 可以根据实际需求调整读取循环的频率，比如在每次读取后加Thread.Sleep(10)减少CPU占用

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