0

我使用以下代码向数据库中的所有学生发送短信

private void btnsend_Click(object sender, EventArgs e)
    {
        foreach (Control c in Controls)
        {
            c.Enabled = false;
        }
        if (!bgw.IsBusy)
        {
            bgw.RunWorkerAsync();
        }
    }
    private void bgw_DoWork(object sender, DoWorkEventArgs e)
    {
        for (int i = 0; i < dt.Rows.Count; i++)
        {
            Invoke((MethodInvoker)delegate()
            {
                using (var sp = new SerialPort(cbcomport.Text))
                {
                    sp.Open();
                    sp.WriteLine("AT" + Environment.NewLine);
                    sp.WriteLine("AT+CMGF=1" + Environment.NewLine);
                    sp.WriteLine("AT+CMGS=\"" + dt.Rows[i]["PhoneNo"] + "\"" + Environment.NewLine);
                    sp.WriteLine(tbsms.Text + (char)26);
                    if (sp.BytesToRead > 0)
                    {
                        tbsentto.Text = i + 1 + " of " + dt.Rows.Count;
                    }
                }
            });
            Thread.Sleep(5000);
        }
    }
    private void bgw_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
    {
        foreach (Control c in Controls)
        {
            c.Enabled = true;
        }
    }

我的问题是：如果发生异常，例如端口“COM5”不存在，则会向学生发送短信。我想通过按钮重试和取消向用户显示相同的系统消息。如果已经解决了问题。即插入设备后，用户按下重试按钮，我想从同一点恢复线程，如果用户按下取消按钮，我想停止暂停的线程。

4

3 回答 3

1

尝试这个

private void btnsend_Click(object sender, EventArgs e)
    {
        foreach (Control c in Controls)
        {
            c.Enabled = false;
        }
        if (!bgw.IsBusy)
        {
            bgw.RunWorkerAsync();
        }
    }
    private void bgw_DoWork(object sender, DoWorkEventArgs e)
    {
        for (int i = 0; i < dt.Rows.Count; i++)
        {
            if ((bgw.CancellationPending == true))
            {

                e.Cancel = true;
                break;
            }
            else
            {
                Invoke((MethodInvoker)delegate()
                {
                    using (var sp = new SerialPort(cbcomport.Text))
                    {
                        try
                        {
                            sp.Open();
                            sp.WriteLine("AT" + Environment.NewLine);
                            sp.WriteLine("AT+CMGF=1" + Environment.NewLine);
                            sp.WriteLine("AT+CMGS=\"" + dt.Rows[i]["PhoneNo"] + "\"" + Environment.NewLine);
                            sp.WriteLine(tbsms.Text + (char)26);
                            if (sp.BytesToRead > 0)
                            {
                                tbsentto.Text = i + 1 + " of " + dt.Rows.Count;
                            }
                            Thread.Sleep(5000);
                        }
                        catch (Exception ex)
                        {
                            if (MessageBox.Show(ex.Message, "Error", MessageBoxButtons.RetryCancel, MessageBoxIcon.Error) == System.Windows.Forms.DialogResult.Retry)
                            {
                                try
                                {
                                    sp.Open();
                                    sp.WriteLine("AT" + Environment.NewLine);
                                    sp.WriteLine("AT+CMGF=1" + Environment.NewLine);
                                    sp.WriteLine("AT+CMGS=\"" + dt.Rows[i]["PhoneNo"] + "\"" + Environment.NewLine);
                                    sp.WriteLine(tbsms.Text + (char)26);
                                    if (sp.BytesToRead > 0)
                                    {
                                        tbsentto.Text = i + 1 + " of " + dt.Rows.Count;
                                    }
                                    Thread.Sleep(5000);
                                }
                                catch (Exception ex2)
                                {
                                    MessageBox.Show(ex2.Message, "Error", MessageBoxButtons.OK, MessageBoxIcon.Error);
                                    bgw.CancelAsync();

                                }
                            }
                            else
                            {
                                bgw.CancelAsync();
                            }
                        }
                    }
                });
            }
        }
    }
    private void bgw_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
    {
        foreach (Control c in Controls)
        {
            c.Enabled = true;
        }
    }
于 2012-04-10T09:31:22.980 回答
1

对于这样的方案，一般的想法是您需要：

  • 捕获可能从工作人员抛出的异常（但只有您知道可以处理的异常；捕获所有异常是邪恶的！）
  • 通知UI线程提示用户
  • 暂停执行直到 UI 线程收到输入
  • 如果输入指示，则中止执行

对于最后两项，使用一个可等待的对象，例如 anAutoResetEvent和一个状态变量（即使是 abool也至少会这样做），指示是否应该中止任务。这些变量必须可以从 UI 线程和工作线程访问：

AutoResetEvent pauseEvent(false);
bool shouldAbort;

然后工人的代码变成：

for (int i = 0; i < dt.Rows.Count; i++)
{
    try
    {
        // your existing code goes here
    }
    catch (SomeException ex) // do not catch all exceptions!
    {
        BeginInvoke(...);     // tell the UI thread something bad happened
        pauseEvent.WaitOne(); // and block the worker until user gives input
        if (shouldAbort)
        {
            // cleanup any other resources if required and then
            break;
        }
    }
}

在该BeginInvoke行中，您应该调用一些方法来向用户显示适当的消息并请求说明。BeginInvoke将立即返回，并且工作人员将AutoResetEvent通过调用无限期地阻塞pauseEvent.WaitOne.

UI 方法应查询用户，并在收到响应后发出pauseEvent信号

pauseEvent.Set();

这将解除对工作人员的阻止并允许其恢复执行。由于代码的结构，这意味着它将继续循环的下一次迭代。如果您想让工作人员中止，请设置shouldAbort为true before signaling pauseEvent。

如果您i在catch块内递减，您还可以使代码重试引发异常的迭代（而不是跳过它并继续下一个）。

于 2012-04-07T08:53:46.947 回答
0

您必须sync在线程之间使用对象。尤其是看 这里wait handlers的部分。

于 2012-04-07T08:08:23.470 回答