tpl-dataflow 相关问题

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

通过BufferBlock的反压不工作。(C# TPL Dataflow)

典型的情况是:"生产者快,消费者慢,需要让生产者慢下来。生产者快,消费者慢,需要让生产者慢下来。样例代码,没有像我预期的那样工作(下面解释)。/ 我以为这个区块会像BlockingQueue一样,... ...

回答 1 投票 0

通过BufferBlock的反压不工作。(C# TPL Dataflow)

典型的情况是:"生产者快,消费者慢,需要让生产者慢下来。生产者快,消费者慢,需要让生产者慢下来。样例代码没有像我预期的那样工作(下面解释)。/ 我以为这个区块会像... ...

回答 1 投票 1

通过BufferBlock的背压不工作。(C# TPL Dataflow)

典型的情况是:"生产者快,消费者慢,需要让生产者慢下来。生产者快,消费者慢,需要让生产者慢下来。样例代码没有像我预期的那样工作(下面解释)。/ 我以为这个区块会像... ...

回答 1 投票 2

如何获取Exception的上下文

我使用TaskParallelLibrary DataFlow结合Stephen Cleary设计的Try库(https:/github.comStephenClearyTry)来实现所谓的 "铁路编程",这样我就可以通过 ...

回答 1 投票 1

无法运行TPL数据流管道。

我试图创建一个管道使用TPL Dataflow。到目前为止,我已经尝试了所有可能的方法来移动数据从第一块到第二块,没有用。我已经链接了块,添加了...。

回答 1 投票 0

Dataflow TPL 实现带前提条件的流水线

我有一个关于使用Dataflow TPL库实现流水线的问题。我的情况是,我有一个软件,需要同时处理一些任务。处理过程是这样的:首先我们...

回答 1 投票 1

如何在TPL数据流中重置推迟的拒绝消息?

我正在使用TDF来处理我的应用程序,目前效果很好,不幸的是,我遇到了一个特殊的问题,似乎不能用现有的Dataflow机制直接处理。我有N个...

回答 1 投票 3

Task.ContinueWith和ActionBlock.LinkTo的具体区别是什么?

我对TPL Dataflow的ActionBlock,TransformBlock等都是新手。我以前经常练习Task.ContinueWith(),如果需要的话,可以创建一个流水线。最近我开始练习TPL Dataflow和它的块。

回答 1 投票 -1

TPL DataFlow未处理所有消息

我正在通过HTTP实现简单的数据加载器,遵循上一个问题C#.NET并行I / O操作(带限制)的提示,并通过限制异步任务进行了回答。我拆分了加载...

回答 1 投票 1


是否可能使任何数据流块类型都由于单个输入而发送多个中间结果?

是否有可能让TransformManyBlocks在创建中间结果时将其发送到下一步,而不是等待整个IEnumerable 填充?我已完成所有测试...

回答 1 投票 0

TPL数据流加速?

我想知道以下代码是否可以优化以更快地执行。目前,在一个非常简单的数据流结构上,我目前似乎每秒最多可以收到140万条简单消息。我知道...

回答 4 投票 5

TPL数据流,是否可以替代JoinBlock限制?

我正在寻找JoinBlock的替代方法,该方法可以通过n-TransformBlocks链接到,并将所有TransformBlock源块的消息合并/合并在一起,以便将这样的集合传递给...

回答 2 投票 5

如何在ASP NET Core中集成TPL数据流

您最近对TPL Dataflow充满了兴趣,我希望将其集成到我的ASP .NET Core应用程序中。我想将其用作管道,其中来自不同部分的多种方法...

回答 1 投票 0

具有有限容量的变换块中的TPL数据流异常

我需要构建将处理许多消息的TPL数据流管道。因为有很多消息,所以我不能简单地将它们发布到BufferBlock的无限队列中,否则我将面对内存...

回答 1 投票 9

这是TPL Dataflow的工作吗?

我在不同的任务上运行了非常典型的生产者/消费者模型。任务1:从二进制文件中读取一批byte [],并为每个字节数组集合启动一个新任务。 (操作是...

回答 2 投票 11

每主机使用HttpClient和Polly发送并行请求,以正常处理429个响应

简介:我正在构建一个单节点Web搜寻器,以仅验证.NET Core控制台应用程序中的URL是否正确200。我在向其发送请求的不同主机上有一组URL ...

回答 2 投票 3

取消TPL数据流块的正确方法

我正在使用TPL块来执行可能被用户取消的操作:我提出了两个选择,首先我取消整个块,但不取消块内的操作,如下所示:...

回答 1 投票 2

ITargetBlock中的重试策略

我需要在工作流程中引入重试策略。假设有3个块以这种方式连接:varexecutionOptions = new ExecutionDataflowBlockOptions {MaxDegreeOfParallelism = ...

回答 3 投票 11

使用TPL ActionBlock,是否可以在作业完成后添加新项目

我正在我的应用程序中使用TPL ActionBlock来实现并行性。我有一个应用程序,它将根据用户输入执行操作。有时该动作需要更多时间,而有时则不需要,...

回答 1 投票 1

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