ProgressChanged 回调上的 BackgroundWorker 和 UserState 问题

Question

看来我不理解后台工作者中用户状态的概念。 我正在处理的应用程序中遇到问题，我需要解释为什么会发生我没有预料到的事情。

我构建了一个演示应用程序来更简单地重现该问题：

public class Tester
{
    private BackgroundWorker _worker = new BackgroundWorker();

    public void performTest()
    {
        Tester tester = new Tester();
        tester.crunchSomeNumbers((obj, arg) =>
        {
            WorkerArgument userState = arg.UserState as WorkerArgument;
            Console.WriteLine(string.Format("Progress: {0}; Calculation result: {1}", arg.ProgressPercentage, userState.CalculationResult));
        });
    }

    public void crunchSomeNumbers(Action<object,ProgressChangedEventArgs> onProgressChanged)
    {
        _worker.DoWork += new DoWorkEventHandler(worker_DoWork);
        _worker.ProgressChanged += new ProgressChangedEventHandler(onProgressChanged);
        _worker.WorkerReportsProgress = true;
        _worker.RunWorkerAsync(new WorkerArgument { CalculationResult=-1, BaseNumber = 10 });
    }

    void worker_DoWork(object sender, DoWorkEventArgs e)
    {
        BackgroundWorker worker = sender as BackgroundWorker;
        WorkerArgument arg = e.Argument as WorkerArgument;

        for (int i = 0; i < 10; i++)
        {
            // calculate total with basenumber
            double result = arg.BaseNumber * (i * 10);
            arg.CalculationResult = result;
            worker.ReportProgress(i * 10, arg);
        }
    }

    public class WorkerArgument
    {
        public int BaseNumber { get; set; }
        public double CalculationResult { get; set; }
    }
}

如果您在控制台应用程序中运行此代码：

class Program
{
    static void Main(string[] args)
    {
        Tester tester = new Tester();
        tester.performTest();

        Console.ReadLine();
    }
}

结果如下：

我不明白的是为什么计算结果总是相同的，而你可以清楚地看到它在每次计算中运行时应该不同 DoWork 方法的 forloop。

Answer 1

您假设事件在循环的下一次迭代之前引发并执行。不幸的是，这是不正确的。

发生的情况是，您的 for 循环在第一个事件执行之前完成。因此，在调用 Console.WriteLine 之前，userState.CalculationResult 位于 900。如果将 for top 更改为

for (int i = 0; < 1000000; i++)

您应该会看到数量有所增加，但在所有事件执行完毕之前它就达到了最大数量。

另一种方法是在调用worker.ReportProgress之前放置一个Console.WriteLine。您将看到 for 循环的完成顺序与事件报告不同。它在第一个事件代码输出上不会那么完整，因为 Console.WriteLine 是一个非常慢的调用，并且大大减慢了 for 循环的执行速度。

多线程需要记住的令人兴奋的问题之一是调用事件是非阻塞的。

Answer 2

有两个问题：

1）循环在第一个事件处理程序执行之前执行
如果在调用 ReportProgress 后冻结后台工作线程执行，您可以看到它。

arg.CalculationResult = result;
worker.ReportProgress(i * 10, arg);
Thread.Sleep(500);

2) 您正在使用 WorkerArgument 的一个实例 - 因此，当执行事件处理程序时，它具有当前的 WorkerArgument 值，而不是引发事件时的值。当您引发事件时，也可以看到这只是传递新的参数实例。

worker.ReportProgress(i * 10, new WorkerArgument(){ CalculationResult = result });

Answer 3

我无法直接发现问题，但这可能与匿名方法和变量固定有关。尝试通过将每个匿名方法或 lambda 重写为正确的方法来缩小范围，并查看问题是否仍然存在。

Answer 4

您需要调用传入的工作人员：

void worker_DoWork(object sender, DoWorkEventArgs e)
{
    BackgroundWorker this_worker = sender as BackgroundWorker;
    WorkerArgument arg = e.Argument as WorkerArgument;

    for (int i = 0; i < 10; i++)
    {
        // calculate total with basenumber
        double result = arg.BaseNumber * (i * 10);
        arg.CalculationResult = result;
        this_worker.ReportProgress(i * 10, arg);
    }
}