使用.NET标准库实现多任务并行处理的详细过程

using System;
using System.Threading.Tasks;
class Program
{
    static void Main()
    {
        int[] data = new int[1000000];
        // 初始化数据
        for (int i = 0; i < data.Length; i++)
        {
            data[i] = i;
        }
        // 并行处理
        Parallel.For(0, data.Length, i => 
        {
            data[i] = Compute(data[i]);
        });
        Console.WriteLine("处理完成");
    }
    static int Compute(int value)
    {
        // 模拟计算密集型操作
        return (int)(Math.Sqrt(value) * Math.Pow(value, 0.25));
    }
}

using System;
using System.Linq;
class Program
{
    static void Main()
    {
        var source = Enumerable.Range(1, 1000000);
        // 并行查询
        var results = source.AsParallel()
                            .Where(x => x % 2 == 0)
                            .Select(x => Math.Sqrt(x))
                            .ToList();
        Console.WriteLine($"找到 {results.Count} 个偶数的平方根");
    }
}

using System;
using System.Net.Http;
using System.Threading.Tasks;
class Program
{
    static async Task Main()
    {
        var urls = new[] 
        {
            "https://example.com/api/data1",
            "https://example.com/api/data2",
            "https://example.com/api/data3"
        };
        var httpClient = new HttpClient();
        var tasks = urls.Select(url => httpClient.GetStringAsync(url));
        // 并行执行所有请求
        var results = await Task.WhenAll(tasks);
        foreach (var result in results)
        {
            Console.WriteLine($"获取到数据，长度: {result.Length}");
        }
    }
}

using System;
using System.Threading.Tasks;
class Program
{
    static async Task Main()
    {
        var tasks = Enumerable.Range(1, 100).Select(async i => 
        {
            await Task.Delay(100); // 模拟I/O操作
            Console.WriteLine($"处理任务 {i}");
            return i * 2;
        });
        // 限制最大并发数为10
        var results = await ProcessWithConcurrency(tasks, 10);
        Console.WriteLine($"处理完成，共 {results.Length} 个结果");
    }
    static async Task<T[]> ProcessWithConcurrency<T>(IEnumerable<Task<T>> tasks, int maxConcurrency)
    {
        var allTasks = new List<Task<T>>();
        var activeTasks = new HashSet<Task<T>>();
        foreach (var task in tasks)
        {
            if (activeTasks.Count >= maxConcurrency)
            {
                var completed = await Task.WhenAny(activeTasks);
                activeTasks.Remove(completed);
            }
            activeTasks.Add(task);
            allTasks.Add(task);
        }
        return await Task.WhenAll(allTasks);
    }
}