标签：tpl-dataflow
-
TransformBlock之后如何写入对象？ - c#
我有一个需要迭代并行处理的对象的列表。这是我需要做的： foreach (var r in results) { r.SomeList = await apiHelper.Get(r.Id); } 由于我想对其进行parellelize，因此我尝试使用Parallel.ForEach（），但它没有等到所有事情都完成之后才开始使用apiHelper.Get（） […]
-
在ITargetBlock <TInput>中重试策略 - c#
我需要将重试策略引入工作流程。假设有3个块以这种方式连接： var executionOptions = new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 3 }; var buffer = new BufferBlock<int>(); var processing = n […]