监控 Parallel.ForEach 的进度

Question

尝试监视 Parallel.ForEach 循环的进度我已经尝试了 这个问题中提出的建议 但不幸的是我仍然无法实现我想要的。

基本上，当我尝试建议的实现（使用计时器）时遇到的第一个问题是 Parallel.ForEach 方法是阻塞调用，因此计时器滴答回调没有发生。

所以我尝试将 Parallel.ForEach 循环放入后台工作线程中。这实际上允许计时器滴答事件发生，但我的计数器值在 ForEach 操作完成之前永远不会更新。

这是代码的基本思想（与后台工作者）。

private StockList _StockListToProcess = null;

private static Int64 ItemsProcessed = 0;

private System.Windows.Threading.DispatcherTimer _timer = null;

private System.ComponentModel.BackgroundWorker _backWorker = null;

progressBar1.Minimum = 1;
progressBar1.Maximum = this._StockListToProcess.Count;

MainWindow.ItemsProcessed = 0;

this._timer = new System.Windows.Threading.DispatcherTimer();
this._timer.Interval = TimeSpan.FromMilliseconds(100);
this._timer.Tick += timer_Tick;
this._timer.Start();

this._backWorker = new System.ComponentModel.BackgroundWorker();

this._backWorker.DoWork += delegate(object o, System.ComponentModel.DoWorkEventArgs args)
{
    Parallel.ForEach(this._StockListToProcess, new ParallelOptions() { MaxDegreeOfParallelism = 5 },
                     (Stock stock) =>
                         {
                             MyWebServiceClient serviceClient = new MyWebServiceClient ();
                             MyWebServiceClient.ResponseEnum result = (MyWebServiceClient .ResponseEnum)serviceClient.SetProductPricing(token.LoginName, token.LoginPassword, token.SiteID.ToString(), stock.ProductCode, stock.ProductPrice);
                             System.Threading.Interlocked.Increment(ref MainWindow.ItemsProcessed);
                         });

    this._timer.Stop();
};

private void timer_Tick(object sender, EventArgs e)
{
    progressBar1.Value = MainWindow.ItemsProcessed;
}

我错过了什么？

Answer 1

我要尝试说定时器和后台工作者的嵌套正在给你带来悲伤。

如果可能的话，我建议您避免使用 Reactive Extensions for . NET（接收）。

如果您这样做，您的代码将如下所示：

progressBar1.Minimum = 1;
progressBar1.Maximum = this._StockListToProcess.Count;

var itemsProcessed = 0;
var updater = new Subject<Unit>(Scheduler.Dispatcher);
updater.Subscribe(u =>
{
    itemsProcessed += 1; //Rx serializes "OnNext" calls so this is safe.
    progressBar1.Value = itemsProcessed;
});

Parallel.ForEach(this._StockListToProcess, new ParallelOptions() { MaxDegreeOfParallelism = 5 },
    (Stock stock) =>
        {
            MyWebServiceClient serviceClient = new MyWebServiceClient ();
            MyWebServiceClient.ResponseEnum result = (MyWebServiceClient .ResponseEnum)serviceClient.SetProductPricing(token.LoginName, token.LoginPassword, token.SiteID.ToString(), stock.ProductCode, stock.ProductPrice);
            updater.OnNext(new Unit());
        });

updater.OnCompleted();

我使用一段虚拟代码进行了测试，它工作得很好，因此，如果您足够勇敢，您应该能够毫无困难地运行它。 :-)

Answer 2

尽管我确实很欣赏 Enigmativity 发布的解决方案，但经过一番搜索后，我发现了我认为解决此问题的正确实现。一种不需要任何其他框架来实现的框架。

有关完整概述 请参阅这篇文章。

Answer 3

如果您在主线程中使用普通计时器并通过 ConcurrentDictionary 传递信息会怎样？