TPL Dataflow：如何确保一个工作块完成后再执行下一个？

刚上手TPL Dataflow确实容易有点懵，尤其是想控制工作块的执行顺序时，很容易踩坑。结合你做文件复制+上传的场景，我给你分两种常见情况讲讲怎么实现“一个工作块完成后再执行下一个”的需求：

情况1：整批文件先全部复制完成，再统一上传 #

如果你的业务逻辑要求必须等所有文件都复制到目标位置（比如临时目录）后，再启动上传流程，那可以通过等待工作块的Completion任务来实现串行：

// 1. 创建文件复制块：可以设置并行度提高复制效率
var copyBlock = new ActionBlock<FileInfo>(file =>
{
    string tempPath = Path.Combine("your-temp-folder", file.Name);
    File.Copy(file.FullName, tempPath, overwrite: true);
    Console.WriteLine($"完成文件复制：{file.Name}");
}, new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 4 });

// 2. 创建文件上传块
var uploadBlock = new ActionBlock<FileInfo>(file =>
{
    string tempPath = Path.Combine("your-temp-folder", file.Name);
    // 这里替换成你的上传逻辑
    UploadFileToServer(tempPath);
    Console.WriteLine($"完成文件上传：{file.Name}");
}, new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 2 });

// 3. 先处理所有复制任务
// 优先发送高优先级文件
foreach (var highPriorityFile in yourHighPriorityFiles)
{
    await copyBlock.SendAsync(highPriorityFile);
}
// 再发送普通优先级文件
foreach (var normalFile in yourNormalPriorityFiles)
{
    await copyBlock.SendAsync(normalFile);
}

// 标记复制块不再接收新任务，并等待所有复制任务完成
copyBlock.Complete();
await copyBlock.Completion;

// 4. 复制完成后，启动上传任务
foreach (var highPriorityFile in yourHighPriorityFiles)
{
    await uploadBlock.SendAsync(highPriorityFile);
}
foreach (var normalFile in yourNormalPriorityFiles)
{
    await uploadBlock.SendAsync(normalFile);
}

uploadBlock.Complete();
await uploadBlock.Completion;

这种方式的核心是：先把所有文件发送给复制块，等复制块的Completion任务完成（意味着所有复制工作都结束），再开始向上传块发送任务，从宏观上保证了“复制全完成→再上传”的串行顺序。

情况2：单个文件复制完成后立即上传（按优先级串行处理每个文件的流程） #

如果你的需求是单个文件复制完就立刻上传，同时整体要保证高优先级文件先处理，那可以通过链接工作块+传播完成状态来实现：

// 1. 复制块：处理复制逻辑，输出复制后的文件信息
var copyBlock = new TransformBlock<FileInfo, FileInfo>(file =>
{
    string tempPath = Path.Combine("your-temp-folder", file.Name);
    File.Copy(file.FullName, tempPath, overwrite: true);
    Console.WriteLine($"完成文件复制：{file.Name}");
    return file;
}, new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 4 });

// 2. 上传块：接收复制后的文件，执行上传
var uploadBlock = new ActionBlock<FileInfo>(file =>
{
    string tempPath = Path.Combine("your-temp-folder", file.Name);
    UploadFileToServer(tempPath);
    Console.WriteLine($"完成文件上传：{file.Name}");
}, new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 2 });

// 3. 链接两个块，设置PropagateCompletion=true，让上传块自动感知复制块的完成状态
copyBlock.LinkTo(uploadBlock, new DataflowLinkOptions { PropagateCompletion = true });

// 4. 按优先级发送文件：先高优先级，再普通
foreach (var highPriorityFile in yourHighPriorityFiles)
{
    await copyBlock.SendAsync(highPriorityFile);
}
foreach (var normalFile in yourNormalPriorityFiles)
{
    await copyBlock.SendAsync(normalFile);
}

// 标记复制块完成，上传块会自动接收这个状态，等所有上传任务完成后结束
copyBlock.Complete();
await uploadBlock.Completion;

这种方式下，每个文件会经历“复制→上传”的串行流程，同时因为我们先发送高优先级文件，所以高优先级的文件会被优先处理，普通文件则按顺序跟进。

额外小提示 #

• 如果需要更精细的优先级控制（比如在块内部动态调整任务优先级），可以自定义带有优先级队列的工作块，不过对于你的文件处理场景，先按发送顺序控制优先级基本够用。
• MaxDegreeOfParallelism可以根据你的系统资源调整，复制块可以设高一点，上传块则要看服务器的并发限制。

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