最简数据流管道需三步：定义块→LinkTo链接→Post或SendAsync输入数据；如TransformBlock实现乘2减1，LinkTo单向连接，Post非阻塞入队，SendAsync等待接收。
TPL Dataflow 是 .NET 原生的异步数据流处理库，不是“另一个队列封装”，而是专为构建可伸缩、带背压、拓扑灵活的并发流水线设计的底层原语。它不依赖你手动管理线程或 Task 调度，而是通过 Block 之间的消息传递自动协调并发、缓冲、完成和错误传播。
怎么创建一个最简可用的数据流管道？
核心是三步：定义块 → 链接（LinkTo）→ 输入数据（Post 或 SendAsync）。下面是一个整数乘2再减1的两级流水线：
var multiply = new TransformBlock<int, int>(x => x * 2);
var subtract = new TransformBlock<int, int>(x => x - 1);
<p>multiply.LinkTo(subtract); // 数据从 multiply 流向 subtract</p><p>multiply.Post(5); // 输入 5 → 输出 9（5×2−1）</p><div class="aritcle_card flexRow">
<div class="artcardd flexRow">
<a class="aritcle_card_img" href="/xiazai/skill4292" title="jm-jsjkxyjs02-pzl-803"><img
src="https://img.php.cn/upload/skill/000/000/081/178998482628832.jpg" alt="jm-jsjkxyjs02-pzl-803" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a href="/xiazai/skill4292" title="jm-jsjkxyjs02-pzl-803">jm-jsjkxyjs02-pzl-803</a>
<p>查询全球任意城市的实时天气和未来天气预报</p>
</div>
<a href="/xiazai/skill4292" title="jm-jsjkxyjs02-pzl-803" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span> </a>
</div>
</div><p>// 等待结果
Console.WriteLine(subtract.ReceiveAsync().Result); // 输出 9</p>-
LinkTo是单向、不可逆的连接；调用后，multiply的输出会自动推给subtract -
Post()是同步非阻塞写入，返回bool表示是否成功入队（受BoundedCapacity限制） - 若需等待写入完成（比如确认下游已接收），改用
await multiply.SendAsync(5)
为什么不用 BufferBlock 直接传数据，而要用 TransformBlock？
BufferBlock<T> 只是“中转站”，不处理数据；TransformBlock<TInput, TOutput> 才是真正干活的“处理单元”。常见误用是把所有逻辑堆在 ActionBlock 里，结果无法链式复用、难以测试、丢失类型流。
- 想做“转换”（如
string→JsonElement）、“计算”、“校验”，必须用TransformBlock - 想做“副作用”（如写 DB、发 HTTP、打日志），才用
ActionBlock，且它没有输出，链路在此终止 -
BufferBlock最适合做“解耦缓冲”或“动态路由前哨”，比如接上游不定速生产者，再用LinkTo分发到多个TransformBlock
MaxDegreeOfParallelism 和 BoundedCapacity 怎么配才不崩？
这两个参数直接决定吞吐、延迟和内存安全。设错会导致死锁、OOM 或完全串行化——不是“越大越好”。
-
MaxDegreeOfParallelism = 1（默认）：块内逻辑串行执行，天然线程安全，适合有状态或顺序敏感操作（如按 ID 保序处理） -
MaxDegreeOfParallelism > 1：启用并行，但要求处理函数是纯函数（无共享状态），否则需自行加锁 -
BoundedCapacity = n：限制 Block 内部队列长度。设为1时，Post()会立即返回false（背压生效）；设为0则禁用内部缓冲，强制同步等待消费者空闲 - 典型组合：
new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 4, BoundedCapacity = 100 }
真正难的不是搭出一条管道，而是让多条管道之间能条件分流、错误隔离、优雅完成。比如一个 BroadcastBlock 同时喂给过滤块和审计块，其中一个失败不能拖垮另一个——这需要显式配置 PropagateCompletion = false 和独立的 Fault() 处理。这些细节，不踩几次 InvalidOperationException: The source block has been completed 是意识不到的。
