C#串口关闭时主界面卡死的原因分析和解决方案

private SerialPort comm = new SerialPort();

// 数据接收事件
void comm_DataReceived(object sender, SerialDataReceivedEventArgs e)
{
    int n = comm.BytesToRead;
    byte[] buf = new byte[n];
    comm.Read(buf, 0, n);

    // 更新UI，使用Invoke同步主线程
    this.Invoke(new Action(() =>
    {
        // 更新文本框、日志等UI操作
        textBoxLog.AppendText($"Received: {BitConverter.ToString(buf)}\r\n");
    }));
}

// 打开/关闭按钮点击事件
private void buttonOpenClose_Click(object sender, EventArgs e)
{
    if (comm.IsOpen)
    {
        comm.Close(); // ← 卡死就发生在这里！
    }
    else
    {
        comm.Open();
    }
}

public void Open()
{
    internalSerialStream = new SerialStream(...);
    internalSerialStream.DataReceived += new SerialDataReceivedEventHandler(CatchReceivedEvents);
}

private void CatchReceivedEvents(object src, SerialDataReceivedEventArgs e)
{
    SerialDataReceivedEventHandler eventHandler = DataReceived;
    SerialStream stream = internalSerialStream;

    if ((eventHandler != null) && (stream != null))
    {
        lock (stream)  // ← 锁住了 SerialStream 实例！
        {
            bool raiseEvent = false;
            try {
                raiseEvent = stream.IsOpen && (BytesToRead >= receivedBytesThreshold);
            }
            catch { /* 忽略 */ }
            finally {
                if (raiseEvent)
                    eventHandler(this, e);  // 触发用户定义的 DataReceived 事件
            }
        }
    }
}

public void Close()
{
    Dispose();
}

protected override void Dispose(bool disposing)
{
    if (disposing)
    {
        if (IsOpen)
        {
            internalSerialStream.Flush();
            internalSerialStream.Close();  // ← 关键！
            internalSerialStream = null;
        }
    }
    base.Dispose(disposing);
}

public virtual void Close()
{
    Dispose(true);
    GC.SuppressFinalize(this);
}

protected override void Dispose(bool disposing)
{
    if (_handle != null && !_handle.IsInvalid)
    {
        if (disposing)
        {
            lock (this)  // ← 再次锁住 this（即 SerialStream 实例）
            {
                _handle.Close();
                _handle = null;
            }
        }
        base.Dispose(disposing);
    }
}

private bool _isListening = false;
private bool _isClosing = false;

void comm_DataReceived(object sender, SerialDataReceivedEventArgs e)
{
    if (_isClosing) return;

    // ...读取数据
    if (!_isClosing)
    {
        this.Invoke(new Action(() => { /* 更新UI */ }));
    }
}

private void buttonOpenClose_Click(object sender, EventArgs e)
{
    _isClosing = true;
    try
    {
        if (comm.IsOpen) comm.Close();
    }
    finally
    {
        _isClosing = false;
    }
}

void comm_DataReceived(object sender, SerialDataReceivedEventArgs e)
{
    int n = comm.BytesToRead;
    byte[] buf = new byte[n];
    comm.Read(buf, 0, n);

    // 使用 BeginInvoke 异步提交UI更新任务，不阻塞当前线程
    this.BeginInvoke(new Action(() =>
    {
        textBoxLog.AppendText($"Received: {BitConverter.ToString(buf)}\r\n");
    }));
}

public partial class Form1 : Form
{
    private SerialPort _serialPort = new SerialPort();

    public Form1()
    {
        InitializeComponent();
    }

    private void comm_DataReceived(object sender, SerialDataReceivedEventArgs e)
    {
        if (!_serialPort.IsOpen) return;

        int n = _serialPort.BytesToRead;
        byte[] buffer = new byte[n];
        _serialPort.Read(buffer, 0, n);

        // 异步更新UI，避免阻塞串口线程
        this.BeginInvoke(new Action(() =>
        {
            textBoxLog.AppendText($"[RX] {BitConverter.ToString(buffer)}\r\n");
        }));
    }

    private void buttonOpenClose_Click(object sender, EventArgs e)
    {
        if (_serialPort.IsOpen)
        {
            _serialPort.Close(); // 不再卡死！
            buttonOpenClose.Text = "打开串口";
        }
        else
        {
            _serialPort.PortName = "COM3";
            _serialPort.BaudRate = 9600;
            _serialPort.DataReceived += comm_DataReceived;
            _serialPort.Open();
            buttonOpenClose.Text = "关闭串口";
        }
    }
}