如何在完成循环中的任何任务后，将值传递给另一个方法，返回循环，并等待下一个任务完成？

Question

有 2 种方法，一种方法依赖于另一种方法。我需要将几个文件并行发送到服务器，首先来自服务器的答案，然后将其发送到DownloadFileAsync 方法，并对其余文件执行相同操作（无需立即等待所有答案，发送它们（答案来自服务器）到DownloadFileAsync() 方法，因为它们被接收）。

public async Task CompressAllFilesAsync(List<UserFile> files, string outputpath)
{
    await UploadAllFilesAsync(files);
    await DownloadAllFilesAsync(files, outputpath);
}

public async Task UploadAllFilesAsync(List<UserFile> files)
{
    IEnumerable<Task> allTasks = files.Select(async (file, i) =>
        files[i].FileLink = await UploadFileAsync(files[i])
    );

    await Task.WhenAll(allTasks);
}

public async Task DownloadAllFilesAsync(List<UserFile> files, string outputpath)
{
    IEnumerable<Task> allTasks = files.Select((file, i) =>
        DownloadFileAsync(files[i].FileLink,
        Path.Combine(outputpath, $"{files[i].FileName}")
    ));

    await Task.WhenAll(allTasks);
}

现在程序在运行DownloadAllFilesAsync() 方法之前等待来自服务器的所有答案（可下载文件的链接）。

Answer 1

您可以考虑使用新的 (.NET 6) API Parallel.ForEachAsync，并为每个 UserFile 依次执行 UploadFileAsync 和 DownloadFileAsync，但与其他文件同时执行：

public async Task CompressAllFilesAsync(List<UserFile> files, string outputPath)
{
    var options = new ParallelOptions() { MaxDegreeOfParallelism = 10 };
    await Parallel.ForEachAsync(files, options, async (file, ct) =>
    {
        await UploadFileAsync(file);
        await DownloadFileAsync(file.FileLink,
            Path.Combine(outputPath, $"{file.FileName}"));
    });
}

UploadFileAsync 和 DownloadFileAsync 将在 ThreadPool 线程上调用。这应该不是问题，除非这些方法与线程仿射组件（如 UI 控件）交互。

Answer 2

public async Task CompressAllFilesAsync(List<UserFile> files, string outputpath) {
    SemaphoreSlim throttler = new SemaphoreSlim(2);

    IEnumerable<Task> allTasks = files.Select(async (file) => {
        await throttler.WaitAsync();

        try {
            file.Link = await UploadFileAsync(file);

            await DownloadFileAsync(file.Link,
                Path.Combine(outputpath, file.Name));
        } finally {
            throttler.Release();
        }
    });

    await Task.WhenAll(allTasks);
}

Answer 3

for (int i = 0; i < fileToSend; i++)
{    
   Task task = new Task(() => 
   {
      SendFile(file[i]);
   });
   task.Start();
}

这样你就可以创建一个后台任务来并行发送你的文件