TPL Dataflow(TDF)是用于构建并发应用程序的.NET库。它通过用于进程内消息传递,数据流和流水线操作的原语来促进面向actor / agent的设计。 TDF建立在.NET 4中的TPL(任务并行库)之上,并与C#,Visual Basic和F#中的异步语言支持集成。 TDF缺少按键(如SSIS)和基于时间的窗口(在Rx中可用)的连接/合并。
通过BufferBlock的反压不工作。(C# TPL Dataflow)
典型的情况是:"生产者快,消费者慢,需要让生产者慢下来。生产者快,消费者慢,需要让生产者慢下来。样例代码,没有像我预期的那样工作(下面解释)。/ 我以为这个区块会像BlockingQueue一样,... ...
通过BufferBlock的反压不工作。(C# TPL Dataflow)
典型的情况是:"生产者快,消费者慢,需要让生产者慢下来。生产者快,消费者慢,需要让生产者慢下来。样例代码没有像我预期的那样工作(下面解释)。/ 我以为这个区块会像... ...
通过BufferBlock的背压不工作。(C# TPL Dataflow)
典型的情况是:"生产者快,消费者慢,需要让生产者慢下来。生产者快,消费者慢,需要让生产者慢下来。样例代码没有像我预期的那样工作(下面解释)。/ 我以为这个区块会像... ...
我使用TaskParallelLibrary DataFlow结合Stephen Cleary设计的Try库(https:/github.comStephenClearyTry)来实现所谓的 "铁路编程",这样我就可以通过 ...
我试图创建一个管道使用TPL Dataflow。到目前为止,我已经尝试了所有可能的方法来移动数据从第一块到第二块,没有用。我已经链接了块,添加了...。
我有一个关于使用Dataflow TPL库实现流水线的问题。我的情况是,我有一个软件,需要同时处理一些任务。处理过程是这样的:首先我们...
我正在使用TDF来处理我的应用程序,目前效果很好,不幸的是,我遇到了一个特殊的问题,似乎不能用现有的Dataflow机制直接处理。我有N个...
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来实现并行性。我有一个应用程序,它将根据用户输入执行操作。有时该动作需要更多时间,而有时则不需要,...