我正在使用BackgroundWorker
线程调用一个小例程,它接收来自MSMQ的消息,一旦消息到达MSMQ队列(消息到达msmq,每隔5秒)它涉及到我的应用程序这是使用BackgroundWorker
线程。以下是我的Win Form类。我是线程的新手,所以如果我做错了什么,请请谅解BackgroundWorker线程不会停止winforms c#
问题:我的应用程序是MDI应用程序,当我第一次执行我的应用程序时,它工作得很好,一收到MSMQ消息,队列,这是每5秒,但是当我关闭这个表单时,它是一个子表单,它关闭的很好,但是在打开同样的表单后,我正在接收来自MSMQ的消息,并持续了10秒的达赖,所以这意味着我正在搞乱一些东西在后台工作线程中,我试图取消这个后台工作线程,但是我失败了,无法正确地执行或终止线程。请帮助并分享您的体验。下面是我的表单代码。
public partial class FrmBooking : BookingManager.Core.BaseForm.BaseForm
{
internal const string queName = @"messageServer\private$\Response";
private Int32 counter = 0;
BackgroundWorker backgroundWorker1 = new BackgroundWorker();
public FrmBooking()
{
InitializeComponent();
backgroundWorker1.WorkerReportsProgress = true;
backgroundWorker1.WorkerSupportsCancellation = true;
backgroundWorker1.RunWorkerCompleted+=new RunWorkerCompletedEventHandler(backgroundWorker1_RunWorkerCompleted);
backgroundWorker1.ProgressChanged+=new ProgressChangedEventHandler(backgroundWorker1_ProgressChanged);
backgroundWorker1.DoWork+=new DoWorkEventHandler(backgroundWorker1_DoWork);
}
private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
{
BackgroundWorker bgWorker = sender as BackgroundWorker;
if (bgWorker.CancellationPending)
{
e.Cancel = true;
return;
}
try
{
MessageQueue messageQueue = null;
if (MessageQueue.Exists(queName))
{
messageQueue = new MessageQueue(queName);
}
else
{
MessageQueue.Create(queName);
}
messageQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(String) });
System.Messaging.Message msg = messageQueue.Receive();
bgWorker.ReportProgress(100, msg);
}
catch (Exception ex) { }
}
private void backgroundWorker1_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
if (!e.Cancelled)
{
backgroundWorker1.RunWorkerAsync();
}
}
private void backgroundWorker1_ProgressChanged(object sender, ProgressChangedEventArgs e)
{
System.Messaging.Message msg = e.UserState as System.Messaging.Message;
listBoxControl1.Items.Add(msg.Body.ToString());
counter++;
labelControl1.Text = String.Format("Total messages received {0}", counter.ToString());
}
private void FrmBooking_Load(object sender, EventArgs e)
{
backgroundWorker1.RunWorkerAsync();
}
}
是的,当我关闭窗体我想说backgroundworker.cancelasync(),但此行的事帮助。你是对的参考是一些如何活着,不知道我怎么能阻止它...仍然尝试 – Shax 2011-12-18 09:44:23