using System;
using System.Threading;
using System.Threading.Tasks;

class Program
{
    static int currentFile = 0;
    static object lockObject = new object();

    static void Main(string[] args)
    {
        const int NUM_FILES = 1000;
        const int NUM_THREADS = 20;

        // 創(chuàng)建一個(gè)計(jì)數(shù)器，以便在所有線程完成后更新狀態(tài)。
        CountdownEvent countdown = new CountdownEvent(NUM_THREADS);

        // 創(chuàng)建20個(gè)下載線程
        for (int i = 0; i < NUM_THREADS; i++)
        {
            int threadIndex = i;
            Task.Run(() =>
            {
                // 模擬下載過(guò)程
                for (int j = threadIndex; j < NUM_FILES; j += NUM_THREADS)
                {
                    DownloadFile(j);
                    ReportProgress(NUM_FILES);  // 報(bào)告下載進(jìn)度
                }

                // 當(dāng)前線程完成下載，向計(jì)數(shù)器發(fā)信號(hào)。
                countdown.Signal();
            });
        }

        // 等待所有線程完成
        countdown.Wait();

        // 所有線程都已完成，將狀態(tài)標(biāo)記為已完成。
        Console.WriteLine("所有文件下載已完成！");
    }

    static void DownloadFile(int fileIndex)
    {
        // 模擬下載過(guò)程
        Thread.Sleep(100);   // 假設(shè)每個(gè)文件需要10毫秒下載
        Console.WriteLine($"文件 #{fileIndex} 已下載完畢！");
    }

    static void ReportProgress(int NUM_FILES)
    {
        lock(lockObject)
        {
            int current = Interlocked.Increment(ref currentFile);
            Console.WriteLine($"當(dāng)前進(jìn)度：{current}/{NUM_FILES}");
        }
    }
}

using System;
using System.Threading.Tasks;
using System.Collections.Concurrent;

class Program
{
    static int currentFile = 0;
    static object lockObject = new object();
    static void Main(string[] args)
    {
        const int NUM_FILES = 1000;

        // 使用ParallelOptions來(lái)跟蹤并行任務(wù)的進(jìn)度
        var parallelOptions = new ParallelOptions
        {
            MaxDegreeOfParallelism = 20 // 設(shè)置最大并行度
        };

        // 使用Parallel.ForEach并行下載文件
        Parallel.ForEach(
            Partitioner.Create(0, NUM_FILES), // 使用分區(qū)器創(chuàng)建任務(wù)范圍
            parallelOptions,
            (range, loopState) =>
            {
                for (int j = range.Item1; j < range.Item2; j++)
                {
                    DownloadFile(j);
                    ReportProgress(NUM_FILES);  // 報(bào)告下載進(jìn)度
                }
            });

        // 所有任務(wù)完成后輸出信息
        Console.WriteLine("所有文件下載已完成！");
    }

    static void DownloadFile(int fileIndex)
    {
        // 模擬下載過(guò)程
        Task.Delay(100).Wait(); // 假設(shè)每個(gè)文件需要100毫秒下載
        Console.WriteLine($"文件 #{fileIndex} 已下載完畢！");
    }

    static void ReportProgress(int NUM_FILES)
    {
        lock(lockObject)
        {
            int current = Interlocked.Increment(ref currentFile);
            Console.WriteLine($"當(dāng)前進(jìn)度：{current}/{NUM_FILES}");
        }
    }
}