BackgroundWorker ReportProgress竞赛条件

Question

下面的代码是BackgroundWorker的最基本的示例。

所以基本上有两个线程：一个主线程和一个工作线程。每当工作线程调用ReportProgress时，都会在主线程上调用bw_ProgressChanged（这是BackgroundWorker的工作方式）。

如果工作线程正在毫无延迟地调用ReportProgress，则主线程不会按顺序处理bw_ProgressChanged调用。有人可以更深入地解释为什么会这样吗？

using System;
using System.ComponentModel;
using System.Threading;

namespace _0042_BackgroundWorkerReportProgress
{
    class Program
    {
        static BackgroundWorker _bw;

        static void Main()
        {
            _bw = new BackgroundWorker
            {
                WorkerReportsProgress = true,
                WorkerSupportsCancellation = true
            };
            _bw.DoWork += bw_DoWork;
            _bw.ProgressChanged += bw_ProgressChanged;
            _bw.RunWorkerCompleted += bw_RunWorkerCompleted;

            _bw.RunWorkerAsync("Hello to worker");

            Console.WriteLine("Press Enter in the next 5 seconds to cancel");
            Console.ReadLine();
            if (_bw.IsBusy) _bw.CancelAsync();
            Console.ReadLine();
        }

        static void bw_DoWork(object sender, DoWorkEventArgs e)
        {
            for (int i = 0; i <= 100; i += 20)
            {
                if (_bw.CancellationPending) { e.Cancel = true; return; }
                _bw.ReportProgress(i);
                Thread.Sleep(1000);  // Without this, there is a race condition.
            }                            
            e.Result = 123;
        }

        static void bw_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
        {
            if (e.Cancelled)
                Console.WriteLine("You canceled!");
            else if (e.Error != null)
                Console.WriteLine("Worker exception: " + e.Error.ToString());
            else
                Console.WriteLine("Complete: " + e.Result);
        }

        static void bw_ProgressChanged(object sender, ProgressChangedEventArgs e)
        {
            Console.WriteLine("Reached " + e.ProgressPercentage + "%");
        }
    }
}

Answer 1

BackgroundWorker在其BackgroundWorker被调用（SynchronizationContext）时捕获当前的RunWorkerAsync。调用source code方法（ReportProgress）时，它将通过发布到先前捕获的source code来调用ProgressChanged事件。如果没有要捕获的SynchronizationContext（默认情况下在控制台应用程序中发生），则将创建基SynchronizationContext.Current类的实例并将其存储为捕获的上下文：

SynchronizationContext类是一个基类，提供了没有同步的自由线程上下文。

这意味着SynchronizationContext事件是在随机的SynchronizationContext线程中调用的。

[如果要在控制台应用程序中使用ProgressChanged类，并且使其行为与WinForms / WPF应用程序类似，则必须安装非自由线程的ThreadPool实现。您可以找到合适的实现BackgroundWorker。