多线程 C# serialPort1_DataReceived 事件不会触发

如何解决多线程 C# serialPort1_DataReceived 事件不会触发

我向串行端口读/写数据，我想立即查看列表框上的读数。我创建了一个新线程来向串口发送命令。我保持主线程为空，因此，它可以更新 UI，并且串行端口事件处理程序不会被其他东西中断。（我不确定这是正确的方法吗？）

以下代码适用于 while (!dataRecieved) { Thread.Sleep(4000); }，但不适用于 while (!dataRecieved) { Thread.Sleep(100); }。 问题是如果我使用 100ms 睡眠，串行端口事件处理程序只触发一次然后程序停止！（如果我用断点调试 100ms 工作，因为我在进入代码时创建了额外的时间。）如果我等待 4000ms 程序工作。另外，我检查从串口发送数据和接收数据之间的时间是200ms。所以，100ms 是合理的。

代码如下：

public bool dataRecieved = false;

public Form1()
        {
            InitializeComponent();
        }

        public void AppendTextBox(string value)
        {
            this.Invoke((MethodInvoker)delegate { richTextBox1.Text += value + "\n";});
        }

private void button1_Click(object sender,EventArgs e)
        {
            serialPort1.open();
            Thread testThread = new Thread(() => sendThread());
            testThread.Start();
        }

public void serialPort1_DataReceived(object sender,System.IO.Ports.SerialDataReceivedEventArgs e)
        {
            data = serialPort1.ReadLine();
            dataRecieved = true;
        }

public void sendThread()
        {
            for(int i = 0; i<10; i++) 
            {
              serialPort1.WriteLine("AT" + i);
              // Following line creates odd situation:
              // if Thread.Sleep(100),I receive only first data,then program stops(serial port handler doesnt fire!).
              // if Thread.Sleep(4000),I receive all data,successfuly works.
              // But I do not want to wait 4000ms,because I receive answer from device in 200ms.
              while (!dataRecieved) { Thread.Sleep(100); }
              AppendTextBox("Received" + "AT" + i);
              dataRecieved = false;
            }
        } 

我错在哪里？你能提供一个解决方案吗？

解决方法

我什至没有使用新的 Thead 在 SerialPort 上进行读写。您只需要在 Invoke() 中使用更新控制就可以了。下面是我对richTextBox 的更新。您可以将表单 richTextBox 更改为您的列表框。

 public void update_RichTextBox(string message)
        {
            Invoke(new System.Action(() =>
            {
                txtReceivedData.Text += message;
                txtReceivedData.Refresh();
                txtReceivedData.SelectionStart = txtReceivedData.Text.Length;
                txtReceivedData.ScrollToCaret();
            }));
            
        }

以及上面void的使用方法：

if (ComPort.IsOpen)
  {
                ComPort.Write(_inputdata + "\r");
                Form1._Form1.update_RichTextBox(_inputdata + "\r");
                string _receviedData = ComPort.ReadExisting();
                Form1._Form1.update_RichTextBox(respond);
                ComPort.DiscardInBuffer();//delete all data in device's received buffer
                ComPort.DiscardOutBuffer();// delete all data in transmit buffer
  }
else
            {
                MessageBox.Show("haven't yet open COM port");
                return "FLASE";
            }

,

我使用我称之为“跨线程链接器”的东西

#region Cross Thread Linker
public bool ControlInvokeRequired(Control c,Action a)
{
    if (c.InvokeRequired) c.Invoke(new MethodInvoker(delegate { a(); }));
    else return false;
    return true;
}

void Update_RichTextBox(RichTextBox rtb,string Text)
{
    if (ControlInvokeRequired(rtb,() => Update_RichTextBox(rtb,Text))) return;
    rtb.AppendText(Text + Environment.NewLine);
}

#endregion

那么：

Update_RichTextBox(richTextBox1,"Text to append");