如何在异步方法中使用yield return实现流水线，优化UWP文件处理流程

嘿，这个场景我太熟悉了！在UWP里用异步迭代器结合yield return实现流水线处理，确实能解决一次性加载大量文件导致的内存占用过高、处理延迟问题——毕竟不用等所有文件都收集完才开始干活，找到一个就处理一个，效率和体验都能提升不少。

核心思路解析 #

你原来的代码是把所有文件都塞进List<StorageFile>里，等递归遍历完整个文件夹树才返回结果。改用异步迭代器后，我们可以返回IAsyncEnumerable<StorageFile>类型，找到一个文件就用yield return立刻返回，让处理逻辑能马上启动，不用干等着。

改造后的异步遍历方法 #

首先把你的GetFiles方法改成异步迭代器形式，注意方法签名要换成async IAsyncEnumerable<StorageFile>：

// 异步迭代器：逐个返回文件，无需一次性存储所有文件
private async IAsyncEnumerable<StorageFile> GetFilesAsync(StorageFolder folder)
{
    var items = await folder.GetItemsAsync();
    foreach (var item in items)
    {
        // 判断当前项是文件还是文件夹
        if (item is StorageFile file)
        {
            // 找到文件就立刻返回，处理逻辑可以马上开始处理这个文件
            yield return file;
        }
        else if (item is StorageFolder subFolder)
        {
            // 递归遍历子文件夹，用await foreach拿到子文件夹的文件，逐个返回
            await foreach (var subFile in GetFilesAsync(subFolder))
            {
                yield return subFile;
            }
        }
    }
}

流水线式的文件处理逻辑 #

接下来，你的文件处理+删除逻辑就可以写成边遍历边执行的流水线模式，不用等所有文件都收集完：

private async Task ProcessAndDeleteFilesAsync(StorageFolder targetFolder)
{
    // 遍历异步迭代器返回的文件，拿到一个就处理一个
    await foreach (var file in GetFilesAsync(targetFolder))
    {
        try
        {
            // 执行你的文件处理逻辑（比如读取内容、转换格式等）
            await ProcessSingleFileAsync(file);
            
            // 处理完成后删除文件
            await file.DeleteAsync(StorageDeleteOption.PermanentDelete);
        }
        catch (Exception ex)
        {
            // 处理单个文件的异常，避免一个文件出错导致整个流程中断
            Debug.WriteLine($"处理文件 {file.Name} 出错：{ex.Message}");
        }
    }
}

// 示例：单个文件的处理方法，根据你的实际需求修改
private async Task ProcessSingleFileAsync(StorageFile file)
{
    // 比如读取文件内容
    var content = await FileIO.ReadTextAsync(file);
    // 这里写你的具体处理逻辑，比如解析、转换、上传等...
}

几个关键注意点 #

1. 版本要求：异步迭代器需要UWP的Windows SDK版本在18362及以上（对应Windows 10 1903），所以要确保你的项目目标版本符合要求。
2. 内存优化：现在不需要全局的List<StorageFile>了，每个文件处理完就可以被GC回收，内存占用会低很多，尤其是处理大量文件时效果明显。
3. 取消支持：如果需要支持取消操作，可以给迭代器方法添加CancellationToken：

   private async IAsyncEnumerable<StorageFile> GetFilesAsync(StorageFolder folder, [EnumeratorCancellation] CancellationToken cancellationToken)
   {
       // 把GetItemsAsync转换成带取消令牌的Task
       var items = await folder.GetItemsAsync().AsTask(cancellationToken);
       foreach (var item in items)
       {
           // 检查是否取消
           cancellationToken.ThrowIfCancellationRequested();
           
           if (item is StorageFile file)
           {
               yield return file;
           }
           else if (item is StorageFolder subFolder)
           {
               await foreach (var subFile in GetFilesAsync(subFolder, cancellationToken))
               {
                   yield return subFile;
               }
           }
       }
   }
   

   使用时可以通过CancellationTokenSource来触发取消，比如用户点击取消按钮时调用cts.Cancel()。

这样改完之后，你的整个流程就变成了遍历→处理→删除的流水线模式，不用等所有文件都加载完毕才开始工作，内存占用和响应速度都会有明显提升。

内容的提问来源于stack exchange，提问作者Ra'ed al-Araj