c# - Progress<T> 与 Action<T> 有何不同？ (C#)

Question

我一直在使用 Progress<T>并想知道是否可以将其替换为 Action<T> .

在下面的代码中，使用它们中的每一个来报告进度，即 ReportWithProgress()或 ReportWithAction() ，对我没有任何明显的影响。如何progressBar1增加了，字符串在输出窗口上的写法，他们看起来是一样的。

// WinForm application with progressBar1

private void HeavyIO()
{
    Thread.Sleep(20); // assume heavy IO
}

private async Task ReportWithProgress()
{
    IProgress<int> p = new Progress<int>(i => progressBar1.Value = i);

    for (int i = 0; i <= 100; i++)
    {
        await Task.Run(() => HeavyIO()); 
        Console.WriteLine("Progress : " + i);
        p.Report(i);
    }
}

private async Task ReportWithAction()
{
    var a = new Action<int>(i => progressBar1.Value = i);

    for (int i = 0; i <= 100; i++)
    {
        await Task.Run(() => HeavyIO());
        Console.WriteLine("Action : " + i);
        a(i);
    }
} 

但是Progress<T>不能是重新发明轮子。应该有它被实现的原因。谷歌搜索“c# Progress vs Action”并没有给我太多帮助。 Progress 与 Action 有何不同？

Answer 1

从不同的线程调用 progressBar1.Value = i 会导致可怕的 "cross-thread operation not valid"异常(exception)。另一方面，Progress 类将事件分派(dispatch)给 synchronization context。拍摄于施工时刻:

// simplified code, check reference source for actual code

void IProgress<T>.Report(T value)
{
    // post the processing to the captured sync context
    m_synchronizationContext.Post(InvokeHandlers, value);
}

private void InvokeHandlers(object state)
{
    // invoke the handler passed through the constructor
    m_handler?.Invoke((T)state);

    // invoke the ProgressChanged event handler
    ProgressChanged?.Invoke(this, (T)state);
}

这确保了对进度条、标签和其他 UI 元素的所有更新都在(一个且唯一的)GUI 线程上完成。

因此，只有在后台线程的 外部 实例化 Progress 类才有意义，在 UI 线程上调用的方法内:

void Button_Click(object sender, EventArgs e)
{
    // since this is a UI event, instantiating the Progress class
    // here will capture the UI thread context
    var progress = new Progress<int>(i => progressBar1.Value = i);

    // pass this instance to the background task
    Task.Run(() => ReportWithProgress(progress));
}

async Task ReportWithProgress(IProgress<int> p)
{
    for (int i = 0; i <= 100; i++)
    {
        await Task.Run(() => HeavyIO());
        Console.WriteLine("Progress : " + i);
        p.Report(i);
    }
}