TPL Dataflow（TDF）是用于构建并发应用程序的.NET库。它通过用于进程内消息传递，数据流和流水线操作的原语来促进面向actor / agent的设计。 TDF建立在.NET 4中的TPL（任务并行库）之上，并与C＃，Visual Basic和F＃中的异步语言支持集成。 TDF缺少按键（如SSIS）和基于时间的窗口（在Rx中可用）的连接/合并。
Task.ContinueWith和ActionBlock.LinkTo的具体区别是什么？
我对TPL Dataflow的ActionBlock，TransformBlock等都是新手。我以前经常练习Task.ContinueWith()，如果需要的话，可以创建一个流水线。最近我开始练习TPL Dataflow和它的块。
我正在通过HTTP实现简单的数据加载器，遵循上一个问题C＃.NET并行I / O操作（带限制）的提示，并通过限制异步任务进行了回答。我拆分了加载...
是否可能使任何数据流块类型都由于单个输入而发送多个中间结果？
是否有可能让TransformManyBlocks在创建中间结果时将其发送到下一步，而不是等待整个IEnumerable 填充？我已完成所有测试...
我想知道以下代码是否可以优化以更快地执行。目前，在一个非常简单的数据流结构上，我目前似乎每秒最多可以收到140万条简单消息。我知道...
我正在寻找JoinBlock的替代方法，该方法可以通过n-TransformBlocks链接到，并将所有TransformBlock源块的消息合并/合并在一起，以便将这样的集合传递给...
您最近对TPL Dataflow充满了兴趣，我希望将其集成到我的ASP .NET Core应用程序中。我想将其用作管道，其中来自不同部分的多种方法...
我需要构建将处理许多消息的TPL数据流管道。因为有很多消息，所以我不能简单地将它们发布到BufferBlock的无限队列中，否则我将面对内存...
我在不同的任务上运行了非常典型的生产者/消费者模型。任务1：从二进制文件中读取一批byte []，并为每个字节数组集合启动一个新任务。 （操作是...
每主机使用HttpClient和Polly发送并行请求，以正常处理429个响应
简介：我正在构建一个单节点Web搜寻器，以仅验证.NET Core控制台应用程序中的URL是否正确200。我在向其发送请求的不同主机上有一组URL ...
我正在使用TPL块来执行可能被用户取消的操作：我提出了两个选择，首先我取消整个块，但不取消块内的操作，如下所示：...
我需要在工作流程中引入重试策略。假设有3个块以这种方式连接：varexecutionOptions = new ExecutionDataflowBlockOptions {MaxDegreeOfParallelism = ...
使用TPL ActionBlock，是否可以在作业完成后添加新项目
我正在我的应用程序中使用TPL ActionBlock来实现并行性。我有一个应用程序，它将根据用户输入执行操作。有时该动作需要更多时间，而有时则不需要，...
ActionBlock B从不接收TransformBlock A返回的项目
我的C＃/ WPF应用程序中的TPL数据流网格存在问题。第一个输入项（称为“作业”）始终贯穿整个链，直到最后一个TPL块。但是剩下的工作...
我知道这是一个经常讨论的话题，因为我发现很多帖子都在谈论这个话题。不幸的是，它们似乎都无法解决我的问题，或者是因为我不了解解决方案，还是...
如何在两个变换块都完成后重新编写代码完成的代码？我以为完成意味着将其标记为完成并且“出队列”为空？公共Test（）{...
创建将单个输入转换为多个输出的TPL数据流TransformBlock
我正在基于数据流模式开发一个项目。为此，我使用来自.NET的TPL Dataflow库。我是最近才了解这个图书馆的，所以我仍然是一个新手，几乎一无所知。 ...
如何为同时运行的多个ActionBlock设置CPU优先级？
我有一堆ActionBlocks，每个块都做不同的事情。大数据处理数据，并由TransformBlock连续地馈送数据。其他3个ActionBlock只需在3个文本文件中编写行（...
我正在编写使用TPL数据流的应用程序。我正在尝试配置一个动作块以写入数据库。但是，我需要此操作块才能对...