C# Windows服务中如何用async-await实现最多4个并行大文件下载？

首先直接给结论：完全可以用async-await实现最多4个并行的文件下载，而且这比BackgroundWorker或者手动创建线程更合适。BackgroundWorker是比较老旧的组件，手动线程则容易造成资源浪费，async-await是当前C#异步编程的首选方案。

先澄清一个关键问题：async-await是不是多线程？ #

答案是不一定。async-await本质是一种异步编程的语法糖，它的核心是利用.NET的任务异步模式（TAP）来处理IO密集型操作（比如网络下载）。当你执行await api.Download(model.path)这类IO操作时，当前线程会被释放回线程池，去处理其他任务，等IO操作完成后，才会回到原来的上下文（如果有需要的话）继续执行后续代码。这种方式不需要为每个下载任务单独占用一个线程，能极大提高线程的利用率，尤其适合IO密集型场景。

只有当你在async方法里执行CPU密集型操作（比如await Task.Run(() => { /* 大量计算 */ })）时，才会用到多线程，但你的场景是网络下载，属于IO密集型，大部分时间都在等待网络响应，所以async-await不会额外创建很多线程，效率更高。

你的示例代码存在的问题 #

你当前的代码逻辑有几个潜在问题：

1. 假设Timer_tick是定时器的事件处理程序（比如System.Timers.Timer的Elapsed事件），如果用async void来写这个事件处理程序，定时器可能会在之前的异步操作未完成时再次触发，导致i的计数混乱，可能会启动超过4个并行任务。
2. while (i <4)里的await Download(model)会导致每次必须等一个下载完成后才会启动下一个，不是真正的并行——你想要的是同时最多4个在跑，而不是串行启动到4个后等待。

改进方案：用SemaphoreSlim控制并发数 #

推荐使用SemaphoreSlim来优雅地控制最多4个并行任务，它可以看作是一个异步的“并发计数器”，代码结构会更清晰，也不容易出错。

下面是改进后的示例代码：

// 定义一个信号量，最多允许4个并发
private readonly SemaphoreSlim _downloadSemaphore = new SemaphoreSlim(4, 4);
// 取消令牌，用于服务停止时取消所有下载任务
private CancellationTokenSource _cts;

// 服务启动时初始化
protected override async void OnStart(string[] args)
{
    _cts = new CancellationTokenSource();
    // 启动下载任务的入口，这里假设你有一个获取所有待下载model的方法
    _ = StartDownloadsAsync(_cts.Token);
}

// 服务停止时取消所有任务
protected override void OnStop()
{
    _cts?.Cancel();
    _cts?.Dispose();
    _downloadSemaphore?.Dispose();
}

private async Task StartDownloadsAsync(CancellationToken cancellationToken)
{
    // 获取所有待下载的model，这里替换成你的实际逻辑
    var allModels = GetAllModelsToDownload();
    
    // 创建所有下载任务的列表
    var downloadTasks = new List<Task>();
    
    foreach (var model in allModels)
    {
        // 检查是否已取消
        cancellationToken.ThrowIfCancellationRequested();
        
        // 等待获取信号量许可（最多4个同时获取）
        await _downloadSemaphore.WaitAsync(cancellationToken);
        
        // 启动下载任务，注意用Task.Run或者直接调用异步方法，这里要捕获异常避免影响其他任务
        var task = DownloadModelAsync(model, cancellationToken)
            .ContinueWith(t => 
            {
                // 不管成功还是失败，都要释放信号量
                _downloadSemaphore.Release();
                // 处理任务异常（可选）
                if (t.Exception != null)
                {
                    // 记录日志等
                    Console.WriteLine($"下载model {model.path}失败: {t.Exception.Message}");
                }
            }, cancellationToken);
        
        downloadTasks.Add(task);
    }
    
    // 等待所有下载任务完成
    await Task.WhenAll(downloadTasks);
}

private async Task DownloadModelAsync(XYZ model, CancellationToken cancellationToken)
{
    try
    {
        var result = await api.Download(model.path, cancellationToken);
        // 处理下载结果，比如保存文件等
        // Use Result
    }
    catch (OperationCanceledException)
    {
        // 任务被取消，无需处理
    }
    catch (Exception ex)
    {
        // 处理其他异常
        throw;
    }
}

几个注意点 #

1. 在Windows服务中使用异步代码时，一定要处理好取消逻辑，用CancellationToken来在服务停止时优雅地终止所有正在进行的下载任务，避免服务停止时出现资源泄漏或未完成的操作。
2. 避免使用async void（除了事件处理程序，比如OnStart），尽量用async Task，这样可以更好地处理异常和等待任务完成。
3. SemaphoreSlim的WaitAsync方法可以配合CancellationToken使用，这样在服务停止时，等待获取许可的任务也能被及时取消。

这样的实现既满足了最多4个并行下载的需求，又充分利用了async-await的异步优势，比手动管理线程或使用BackgroundWorker更简洁高效。

内容的提问来源于stack exchange，提问作者Gags