c# - 使用 TPL 的 Parallel.ForEach 时跟踪进度

Question

跟踪以下进度的最佳方式是什么

long total = Products.LongCount();
long current = 0;
double Progress = 0.0;

Parallel.ForEach(Products, product =>
{
    try
    {
        var price = GetPrice(SystemAccount, product);
        SavePrice(product,price);
    }
    finally
    {
        Interlocked.Decrement(ref this.current);
    }});

我想将进度变量从 0.0 更新到 1.0(当前/总计)，但我不想使用任何会对并行性产生不利影响的东西。

Answer 1

Jon 的解决方案很好，如果您需要像这样的简单同步，您的第一次尝试几乎应该总是使用 lock。但是，如果您测量到锁定速度太慢，您应该考虑使用类似 Interlocked 的东西。

在这种情况下，我会使用 Interlocked.Increment 来增加当前计数，并将 Progress 更改为一个属性:

private long total;
private long current;
public double Progress
{
    get
    {
        if (total == 0)
            return 0;
        return (double)current / total;
    }
}

…

this.total = Products.LongCount();
this.current = 0;

Parallel.ForEach(Products, product =>
{
    try
    {
        var price = GetPrice(SystemAccount, product);
        SavePrice(product, price);
    }
    finally
    {
        Interlocked.Increment(ref this.current);
    }
});

此外，您可能想考虑如何处理异常，我不确定以异常结束的迭代是否应该算作已完成。