问使用Parallel.ForEach在控制台应用程序中报告进度

EN

2 --> 20 %  -- Bytes Read = 23971
2 --> 20 %  -- Bytes Read = 23971
2 --> 20 %  -- Bytes Read = 23971
3 --> 30 %  -- Bytes Read = 35909
4 --> 40 %  -- Bytes Read = 47872
5 --> 50 %  -- Bytes Read = 59824
6 --> 60 %  -- Bytes Read = 71775
7 --> 70 %  -- Bytes Read = 83746
8 --> 80 %  -- Bytes Read = 95701
9 --> 90 %  -- Bytes Read = 107686
Elapsed Time: : 702
Press Any Key

using RestSharp;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace RestSharpAsyncTest
{
    public class SomeItem
    {
        public int Id { get; set; }
        public long BytesRead { get; set; }

        public SomeItem(int i)
        {
            this.Id = i;
            this.BytesRead = 0;
        }

        public long ProcessItem()
        {
            var client = new RestClient("http://www.google.com");
            var request = new RestRequest("", Method.GET);

            var restResponse = client.Execute(request);

            return restResponse.RawBytes.Length;
        }
    }

    public class ProgressReport
    {
        public int Counter { get; set; } = 0;
        public long TotalBytesRead { get; set; }
        public int PercentComplete { get; set; }
    }

    class Program
    {
        private static async Task DoSomethingAsync(List<SomeItem> someItems, IProgress<ProgressReport> progress)
        {
            /// Set up the local progress reporter
            ProgressReport progressReport = new ProgressReport();

            System.Diagnostics.Stopwatch watch = new System.Diagnostics.Stopwatch();
            watch.Start();

            await Task.Run(() =>
            {
                Parallel.ForEach(someItems, someItem =>
                {
                    long bytesRead = someItem.ProcessItem();
                    progressReport.Counter++;
                    progressReport.PercentComplete = (progressReport.Counter * 100) / someItems.Count;
                    progressReport.TotalBytesRead += bytesRead;
                    progress.Report(progressReport);                    
                });
            });

            watch.Stop();

            Console.WriteLine("Elapsed Time: : {0}", watch.ElapsedMilliseconds);
        }

        static async Task Main(string[] args)
        {
            Progress<ProgressReport> pr = new Progress<ProgressReport>();
            pr.ProgressChanged += Pr_ProgressChanged;

            // Create some items
            List<SomeItem> someItems = new List<SomeItem>();

            for (int i = 1; i < 11; i++)
                someItems.Add(new SomeItem(i));

            await DoSomethingAsync(someItems, pr);

            Console.WriteLine("Press Any Key");
            Console.ReadKey();
        }

        private static void Pr_ProgressChanged(object sender, ProgressReport e)
        {
            Console.WriteLine($"{e.Counter } --> { e.PercentComplete } %  -- Bytes Read = { e.TotalBytesRead }");
        }
    }
}

public class Program
{
    private static object locker = new object();

lock (locker)
{
    progressReport.Counter++;
    progressReport.PercentComplete = (progressReport.Counter * 100) / someItems.Count;
    progressReport.TotalBytesRead += bytesRead;
    progress.Report(progressReport);
}