c# - Parallel.ForEach x of x

Question

所以我在 c# 4.0 WPF 应用程序中工作，并使用并行 foreach 循环将数据导出到使用我创建的数据库存储库的数据库。我已经使用进度条与并行 foreach 一起导出，但希望能够提供更深入的进度细节，例如导出 25 项中的第 5 项。我遇到的问题很明显，因为它正在运行同时，计数器不起作用，即总数会说类似

exporting 0 of 25
exporting 0 of 25
...
exporting 5 of 25
exporting 5 of 25

任何人都可以指导如何让行为在这样的并行循环中工作:

int runningTotal = 0;
Parallel.ForEach(source, x =>
{
    Repository.Commit(x);
    runningTotal++;
    progressReporter.ReportProgress(() =>
    {
        //Progress bar update
        this.progressFile.Value++;
        this.lblProgress.Text = String
            .Format("Exporting Source {0} of {1}", runningTotal, source.Count)
    });
});

希望这表明我希望实现的目标。

谢谢

Answer 1

当您使用来自多个线程的相同数据时，您应该使用锁定机制来保护它的访问。这可以通过使用 lock 结构轻松完成。

但是，对于您的需要来说，它可能有点过分了。由于您只是递增一个值，因此一个简单的 System.Threading.Interlocked.Increment 就可以了。在 msdn .

int runningTotal = 0;
Parallel.ForEach(source, x =>
{
    Repository.Commit(x);
    Interlocked.Increment(ref runningTotal);
    progressReporter.ReportProgress(() =>
    {
        //Progress bar update
        Interlocked.Increment(ref this.progressFile.Value);
        this.lblProgress.Text = String
            .Format("Exporting Source {0} of {1}", runningTotal, source.Count)
    });
});

编辑:我在 WPF 中做了一个示例。

窗口.xaml:

<Window x:Class="WpfApplication4.MainWindow"
        xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
        xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
        Title="MainWindow" Height="350" Width="525">
    <Grid>
        <Grid.RowDefinitions>
            <RowDefinition Height="50" />
            <RowDefinition />
        </Grid.RowDefinitions>
        <Button Grid.Row="0" Click="Button_Click">Click me</Button>
        <TextBlock Grid.Row="1">
            <TextBlock.Text>
                <MultiBinding StringFormat="Progress: {0}/{1}">
                    <Binding Path="ProgressValue" RelativeSource="{RelativeSource AncestorType=Window, Mode=FindAncestor}" />
                    <Binding Path="ProgressMax" RelativeSource="{RelativeSource AncestorType=Window, Mode=FindAncestor}" />
                </MultiBinding>
            </TextBlock.Text>
        </TextBlock>
    </Grid>
</Window>

窗口.xaml.cs

public partial class MainWindow : Window, INotifyPropertyChanged
{
    public MainWindow()
    {
        InitializeComponent();
    }

    int progressValue;
    public int ProgressValue
    {
        get { return (this.progressValue); }
        set { this.progressValue = value; this.raisePropertyChanged("ProgressValue"); }
    }

    public int ProgressMax
    {
        get { return (100); }
    }

    public event PropertyChangedEventHandler PropertyChanged;

    void raisePropertyChanged(string propertyName)
    {
        if (PropertyChanged != null)
            PropertyChanged(this, new PropertyChangedEventArgs(propertyName));
    }

    private void Button_Click(object sender, RoutedEventArgs e)
    {
        Task.Factory.StartNew(() =>
        {
            int counter = 0;

            Parallel.ForEach(Enumerable.Range(1, 100), i =>
            {
                Interlocked.Increment(ref counter);
                    this.ProgressValue = counter;
                Thread.Sleep(25);
            });
        });
    }
}

我只是使用绑定(bind)来显示指示工作进度的字符串。所有内容都存储在实现 INotifyPropertyChanged 的 Window 中，以强制绑定(bind)刷新并显示更新后的值。它可以很容易地移动到它自己的类中，该类将实现 INotifyPropertyChanged 以获得更清晰的代码。