跨线程操作无效：控件“listBox1”从创建它的线程以外的线程访问

Question

我想将项目添加到 Modbus_request_event 中的 listBox1。我已经完成了为这个问题提供的解决方案并使用 MethodInvoker Delegate 修改了代码，但它仍然不会将项目添加到 listBox1。 这是我的代码

     public void Modbus_Request_Event(object sender, ModbusSlaveRequestEventArgs e)
        {
            //disassemble packet from master
            byte fc = e.Message.FunctionCode;
            byte[] data = e.Message.MessageFrame;
            byte[] byteStartAddress = new byte[] { data[3], data[2] };
            byte[] byteNum = new byte[] { data[5], data[4] };
            short StartAddress = BitConverter.ToInt16(byteStartAddress, 0);
            short NumOfPoint = BitConverter.ToInt16(byteNum, 0);


            string fc1 = Convert.ToString(fc);
           string StartAddress1 = Convert.ToString(StartAddress);
           string NumOfPoints1 = Convert.ToString(NumOfPoint);

           /*Adds the items to listBox1*/
            Invoke(new MethodInvoker(delegate () { listBox1.Items.Add(fc1); listBox1.Items.Add(StartAddress1); listBox1.Items.Add(NumOfPoints1); }));
//it runs infinitely not able to add to listbox//


        }

谁能帮我解决这个问题？

Answer 1

首先，重复的是重复的。您不能从另一个线程修改 UI。在 .NET 4.5 之前，人们会在 control 上使用 Invoke 或 BeginInvoke 将委托编组到 UI 线程并在那里运行。问题的代码虽然调用了Invoke()，但实际上是在它当前所在的线程上运行委托。

简而言之：

Invoke(new MethodInvoker(delegate () { listBox1.Items.Add(fc1); listBox1.Items.Add(StartAddress1); listBox1.Items.Add(NumOfPoints1); }));

就线程而言，本质上与此相同：

listBox1.Items.Add(fc1); listBox1.Items.Add(StartAddress1); listBox1.Items.Add(NumOfPoints1);

使用 .NET 4.5 及更高版本，您可以使用 Progress 报告任何线程或任务的进度，如 Enabling Progress and Cancellation in Async APIs 所示。鉴于最早支持的 .NET 版本是 4.5.2，您可以假设该类随处可用。

通过使用Progress<T> 和IProgress<T> 接口，您可以将事件与用户界面分离，这意味着您可以以任何您想要的方式处理数据，即使是在不同的表单上。您可以将 Modbus 类移动到不同的类或库中，以使其与 UI 分开。

在最简单的情况下，您可以在表单的构造函数中实例化Progress<T> 类，并通过事件处理程序的IProgress<T> 接口调用它，例如：

public class ModbusData
{
    public byte Fc {get; set;}
    public short StartAddress {get; set;}
    public short NumOfPoints {get; set;}
}

public class MyForm : ...
{

    IProgress<ModbusData> _modbusProgress;

    public MyForm()
    {
        __modbusProgress=new Progress<ModbusData>(ReportProgress);
    }

    public void ReportProgress(ModbusData data)
    {
        listBox1.Items.Add(data.fc1.ToString()); 
        listBox1.Items.Add(dta.StartAddress1.ToString()); 
        listBox1.Items.Add(data.NumOfPoints1.ToString()); 
    }

并报告事件的进度，无论它是在哪个线程上引发的：

    public void Modbus_Request_Event(object sender, ModbusSlaveRequestEventArgs e)
    {
        //disassemble packet from master
        byte fc = e.Message.FunctionCode;
        byte[] data = e.Message.MessageFrame;
        byte[] byteStartAddress = new byte[] { data[3], data[2] };
        byte[] byteNum = new byte[] { data[5], data[4] };
        short StartAddress = BitConverter.ToInt16(byteStartAddress, 0);
        short NumOfPoint = BitConverter.ToInt16(byteNum, 0);

        var modData = new ModbusData {
                 Fc = fc,
                 StartAddress = StartAddress,
                 NumOfPoints = NumOfPoint
        };
       _progress.Report(modData);
    }        

如果您决定将 Modbus 类移动到另一个类，您所要做的就是在开始使用它们之前将 IProgress<ModbusData> 实例传递给它们。

例如：

class MyModbusController
{
    IProgress<ModbusData> _modbusProgress;

    public MyModbusController(IProgress<ModbusData> progress)
    {
        _modbusProgress=progress;
    }

    public void Modbus_Request_Event(...)
}

Answer 2

这并不能解决您的问题..，因为您的代码看起来没有错，但这可能有助于制定更好的线程和 gui 解决方案。

您正在使用Invoke 来同步 modbus 线程和 gui 线程。这意味着当接收到 modbus 的事件时，您将项目添加到列表框中。当它调用 gui 线程时，您的 modbus 线程被阻塞。因此，您的 modbus 通信速度取决于 gui 组件的速度。尽量避免这种讨厌的块。如果您每秒收到许多 modbus 事件，您的列表框将被重绘淹没，您的应用程序将被限制。

如何解决这个问题？：

您应该将项目添加到列表（concurrentcollection）并使用计时器来更新您的 gui。通过这种方式，您可以确定何时将接收到的事件（批量）添加到列表框中。一个100ms间隔的定时器就够了。

伪示例代码：

public class Data
{
    public string Fc1 {get; set;}
    public string StartAddress1 {get; set;}
    public string NumOfPoints1 {get; set;}
}

---

ConcurrentQueue<Data> _modbusEvents = new ConcurrentQueue<Data>();


public void Modbus_Request_Event(object sender, ModbusSlaveRequestEventArgs e)
{
    //disassemble packet from master
    byte fc = e.Message.FunctionCode;
    byte[] data = e.Message.MessageFrame;
    byte[] byteStartAddress = new byte[] { data[3], data[2] };
    byte[] byteNum = new byte[] { data[5], data[4] };
    short StartAddress = BitConverter.ToInt16(byteStartAddress, 0);
    short NumOfPoint = BitConverter.ToInt16(byteNum, 0);


    string fc1 = Convert.ToString(fc);
    string StartAddress1 = Convert.ToString(StartAddress);
    string NumOfPoints1 = Convert.ToString(NumOfPoint);

    // add to the concurrentqueue
    _modbusEvents.Add(new Data { Fc1 = fc1, StartAddress1 = StartAddress1, NumOfPoints1 = NumOfPoints1 });

   /*Adds the items to listBox1*/
    //Invoke(new MethodInvoker(delegate () { listBox1.Items.Add(fc1); listBox1.Items.Add(StartAddress1); listBox1.Items.Add(NumOfPoints1); }));
//it runs infinitely not able to add to listbox//

}

---

private void Timer_Tick(object sender, EventArgs e)
{
    if(_modbusEvents.Count > 0)
    {
        listBox1.BeginUpdate();

        while(_modbusEvents.TryDequeue(out var result))
        {
             listBox1.Items.Add(result.Fc1);
             listBox1.Items.Add(result.StartAddress1);
             listBox1.Items.Add(result.NumOfPoints1);
        }

        listBox1.EndUpdate();
    }
}

Answer 3

尝试使用以下代码：

Invoke((MethodInvoker)delegate 
{
listBox1.Items.Add(fc1);
listBox1.Items.Add(StartAddress1);
listBox1.Items.Add(NumOfPoints1);
});