使用 backgroundworker 和事件处理程序的多线程

Question

我正在开发一个示例程序，以使用后台工作程序连接多个设备。每个连接的设备都将作为新对象添加到列表中。完成连接所有设备后，我想为每个连接的设备添加一个事件处理程序。我现在面临的问题是事件处理程序根本没有触发。以下是示例代码。

连接点击按钮事件：

private void btnConnect_Click(object sender, EventArgs e)
{
    using (BackgroundWorker m_oWorker = new BackgroundWorker())
    {
        m_oWorker.DoWork += delegate (object s, DoWorkEventArgs args)
        {
            int iIpStart = 0;
            int iIpEnd = 0;
            string strIp1 = string.Empty;
            string strIp2 = string.Empty;

            list.Clear();

            string[] sIP1 = txtIpStart.Text.Trim().ToString().Split('.');
            string[] sIP2 = txtIpEnd.Text.Trim().ToString().Split('.');

            iIpStart = Convert.ToInt32(sIP1[3]);
            iIpEnd = Convert.ToInt32(sIP2[3]);

            strIp1 = sIP1[0] + "." + sIP1[1] + "." + sIP1[2] + ".";
            strIp2 = sIP2[0] + "." + sIP2[1] + "." + sIP2[2] + ".";

            Ping ping = new Ping();
            PingReply reply = null;

            int iIncre = 0;
            int iVal = (100 / (iIpEnd - iIpStart));
            for (int i = iIpStart; i <= iIpEnd; i++)
            {
                Thread.Sleep(100);

                string strIpconnect = strIp1 + i.ToString();
                Console.Write("ip address : " + strIpconnect + ", status: ");
                reply = ping.Send(strIpconnect);

                if (reply.Status.ToString() == "Success")
                {
                    if (ConnectDevice(strIpconnect))
                    {
                        strLastDevice = strIpconnect + " Connected";
                        isconnected = true;
                    }
                    else
                    {
                        isconnected = false;
                    }
                }
                else
                {
                    isconnected = false;
                }
                m_oWorker.ReportProgress(iIncre);
                iIncre = iIncre + iVal;
            }
            m_oWorker.ReportProgress(100);
        };
        m_oWorker.ProgressChanged += new ProgressChangedEventHandler(m_oWorker_ProgressChanged);
        m_oWorker.RunWorkerCompleted += new RunWorkerCompletedEventHandler(m_oWorker_RunWorkerCompleted);
        m_oWorker.WorkerReportsProgress = true;
        m_oWorker.WorkerSupportsCancellation = true;

        m_oWorker.RunWorkerAsync();
    }
}

ConnectDevice 函数方法。连接的设备将被添加到列表中：

protected bool ConnectDevice(string sIP)
{
    try
    {
        NewSDK sdk = new NewSDK();

        if (sdk.Connect() == true)
        {
            list.Add(new objSDK { sdk = sdk, ipaddress = sIP });
            return true;
        }
        else
        {

        }
    }
    catch() {}
    return false;
}

后台工作者：

void m_oWorker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
    //If it was cancelled midway
    if (e.Cancelled)
    {
        lblStatus.Text = "Task Cancelled.";
    }
    else if (e.Error != null)
    {
        lblStatus.Text = "Error while performing background operation.";
    }
    else
    {
        lblStatus.Text = "Task Completed...";
        btnListen.Enabled = true;
    }
}

void m_oWorker_ProgressChanged(object sender, ProgressChangedEventArgs e)
{
    //Here you play with the main UI thread
    progressBar1.Value = e.ProgressPercentage;
    lblStatus.Text = "Processing......" + progressBar1.Value.ToString() + "%";

    if (isconnected)
    {
        listBox2.Items.Add(strLastDevice);
        string[] ssplit = sDeviceInfo.Split(';');

        foreach (string sword in ssplit)
        {
            listBox1.Items.Add(sword);
        }
    }
}

附加事件的功能：

private void RegisterEvent()
{
    foreach (objSDK obj in list)
    {
        obj.sdk.OnTransaction += () =>
        {
            listBox1.Items.Add("ip : " + obj.IP + " transaction");
        };
    }
}

Answer 1

您已将m_oWorker 声明为局部变量。我猜这是个错误（m_ 前缀只能用于类成员变量）？

此外，您在 using 语句中声明了它，这意味着框架将在 using 块的末尾对其调用 Dispose()。即使你坚持对它的引用（我不认为你这样做），它仍然意味着它的资源将被释放，这可能就是它不处理任何事件的原因。

Answer 2

我通过使用线程和任务尝试了另一种解决方法，并且工作正常。感谢大家的回复