C#，多线程 - 表单未更新

我有一个跨多个线程运行的蒙特卡洛模拟，带有进度条来通知用户它的进展情况。进度条管理是使用 Invoke 在单独的线程中完成的，但表单不会更新。

这是我的代码：

Thread reportingThread = new Thread(() => UpdateProgress(iSims, ref myBag));
reportingThread.Priority = ThreadPriority.AboveNormal;
reportingThread.Start();`

这是正在调用的函数：

private void UpdateProgress(int iSims, ref ConcurrentBag<simResult> myBag)
{
    int iCount;
    string sText;
    if (myBag == null)
        iCount = 0;
    else
        iCount = myBag.Count;
    while (iCount < iSims)
    {
        if (this.Msg.InvokeRequired)
        {
             sText = iCount.ToString() + " simultions of " + iSims + " completed.";
            this.Msg.BeginInvoke((MethodInvoker) delegate() { this.Msg.Text = sText; this.Refresh(); });
        }
       Thread.Sleep(1000);
       iCount = myBag.Count;
    }
}

我已经使用Application.DoEvents((和this.refresh((来尝试强制表单更新，但没有任何反应。

更新：这是调用上述函数的过程

private void ProcessLeases(Boolean bValuePremium)
    {
        int iSims, iNumMonths, iNumYears, iIndex, iNumCores, iSimRef;
        int iNumSimsPerThread, iThread, iAssets, iPriorityLevel;
        string sMsg;
        DateTime dtStart, dtEnd;
        TimeSpan span;
        var threads = new List<Thread>();
        ConcurrentBag<simResult> myBag = new ConcurrentBag<simResult>();
        ConcurrentBag<summaryResult> summBag = new ConcurrentBag<summaryResult>();
        this.Msg.Text = "Updating all settings";
        Application.DoEvents();
        ShowProgressPanel();
        iSims = objSettings.getSimulations();
        iNumCores = Environment.ProcessorCount;
        this.Msg.Text = "Initialising model";
        Application.DoEvents();
        iNumSimsPerThread = Convert.ToInt16(Math.Round(Convert.ToDouble(iSims) / Convert.ToDouble(iNumCores), 0));
        this.Msg.Text = "Spawning " + iNumCores.ToString() + " threads";
        for (iThread = 0; iThread < iNumCores; iThread++)
        {
            int iStart, iEnd;
            if (iThread == 0)
            {
                iStart = (iThread * iNumSimsPerThread) + 1;
                iEnd = ((iThread + 1) * iNumSimsPerThread);
            }
            else
            {
                if (iThread < (iNumCores - 1))
                {
                    iStart = (iThread * iNumSimsPerThread) + 1;
                    iEnd = ((iThread + 1) * iNumSimsPerThread);
                }
                else
                {
                    iStart = (iThread * iNumSimsPerThread) + 1;
                    iEnd = iSims;
                }
            }
            Thread thread = new Thread(() => ProcessParallelMonteCarloTasks(iStart, iEnd, iNumMonths, iSimRef, iSims, ref objDB, iIndex, ref objSettings, ref myBag, ref summBag));
            switch (iPriorityLevel)
            {
                case 1: thread.Priority = ThreadPriority.Highest; break;
                case 2: thread.Priority = ThreadPriority.AboveNormal; break;
                default: thread.Priority = ThreadPriority.Normal; break;
            }
            thread.Start();
            threads.Add(thread);
        }
        // Now start the thread to aggregate the MC results
        Thread MCThread = new Thread(() => objPortfolio.MCAggregateThread(ref summBag, (iSims * iAssets), iNumMonths));
        MCThread.Priority = ThreadPriority.AboveNormal;
        MCThread.Start();
        threads.Add(MCThread);
        // Here we review the CollectionBag size to report progress to the user
        Thread reportingThread = new Thread(() => UpdateProgress(iSims, ref myBag));
        reportingThread.Priority = ThreadPriority.AboveNormal;
        reportingThread.Start();
        // Wait for all threads to complete
        //this.Msg.Text = iNumCores.ToString() + " Threads running.";
        foreach (var thread in threads)
            thread.Join();
        reportingThread.Abort();
        this.Msg.Text = "Aggregating results";
        Application.DoEvents();
        this.Msg.Text = "Preparing Results";
        Application.DoEvents();
        ShowResults();
        ShowResultsPanel();
    }

如您所见，在我的调用调用之前，表单有许多更新，它们都工作正常 - 在每种情况下，我都使用 Application.DoEvents(( 进行更新。

myBag 是一个 ConcurrentBag，每个蒙特卡洛线程都会将其结果转储到其中。通过使用 Count 方法，我可以查看已完成的模拟次数并更新用户。

foreach (var thread in threads)
    thread.Join();

 if (allThreadsAreFinished)  // <-- You'll need to implement something here
 {
      reportingThread.Abort();
      this.Msg.Text = "Preparing Results";         
      ShowResults();
      ShowResultsPanel();
 }

 this.Msg.BeginInvoke((MethodInvoker) delegate() { 
      this.Msg.Text = sText; 
      this.Refresh(); 
 });

this.Msg.InvokeRequired == false