tpl-dataflow 相关问题

TPL Dataflow(TDF)是用于构建并发应用程序的.NET库。它通过用于进程内消息传递,数据流和流水线操作的原语来促进面向actor / agent的设计。 TDF建立在.NET 4中的TPL(任务并行库)之上,并与C#,Visual Basic和F#中的异步语言支持集成。 TDF缺少按键(如SSIS)和基于时间的窗口(在Rx中可用)的连接/合并。

如何正确管理TPL数据流中的完成

我创建了类似于网络爬虫的东西来创建我需要管理的1000多个Web服务的报告。因此,我创建了一个TPL数据流管道来管理获取和处理数据。 ......

回答 1 投票 3

TPL Dataflow块消耗所有可用内存

我有一个具有以下设计的TransformManyBlock:输入:文件的路径输出:IEnumerable文件的内容,一次一行我在一个巨大的文件(61GB)上运行这个块,这是...

回答 2 投票 6

使用数据流管道继续处理循环

我正在玩数据流并尝试学习如何使用它们。我发现很多例子展示了如何使用不同的块,但没有一个真正解释如何处理......

回答 3 投票 0

TPL数据流 - 阻止不按预期处理

我有一组简单的块,大多数是以串行方式处理的,但我有两个块,我想并行处理(processblock1和processblock2)。我刚开始玩...

回答 2 投票 0

TPL数据流:取消

在.Net库中的IDataflowBlock的长列表中,如果我想将整个块集合的执行限制为TimeSpan(例如,5秒),如果我传递一个单独的就足够了...

回答 1 投票 1

等待SendAsync不等待TPL Dataflow BatchBlock

示例程序具有以下BatchBlock:new BatchBlock (10,新的GroupingDataflowBlockOptions {MaxNumberOfGroups = 2});,有60个int数据项被发送到...

回答 2 投票 0

ReceiveAsync中断/中断消息传递

在尝试实现此问题的建议解决方案时,此问题抬头。问题摘要执行从TransformBlock到WriteOnceBlock的ReceiveAsync()调用导致...

回答 1 投票 1

在JoinBlock中,在填充另一个Target时接收目标

我正在将JoinBlock连接到WriteOnceBlock和BufferBlock以填充目标1和2.我的目标是每次JoinBlock从BufferBlock接收消息时,它还会请求值...

回答 1 投票 1

TPL Dataflow从所有传入节点(多个生产者,1个消费者)创建聚合结果数组

请注意以下代码示例。我需要一个聚合器节点,可以链接到任意数量的源,等待所有源发送一条消息,然后在结果[]中组合它们。这个 ...

回答 2 投票 1

贪心JoinBlock解释

在默认的贪婪模式下,即使另一个目标没有形成元组的必要数据,也会接受提供给目标的所有数据。据此,我的理解是我......

回答 1 投票 2

使用TPL Dataflow,我可以取消所有帖子然后添加一个吗?

使用TPL Dataflow库,我想做类似这样的事情:myActionBlock.Post(newValue,cancelAllPreviousPosts:true);似乎ActionBlock上的取消令牌取消了......

回答 3 投票 7

DataflowEx永远不会完成

我试图使用开源lib DataflowEx与下一个Dataflow声明。 class RequestClientFlow:数据流 {private readonly ILogger _logger;私人只读...

回答 1 投票 2

© www.soinside.com 2019 - 2024. All rights reserved.