TPL Dataflow（TDF）是用于构建并发应用程序的.NET库。它通过用于进程内消息传递，数据流和流水线操作的原语来促进面向actor / agent的设计。 TDF建立在.NET 4中的TPL（任务并行库）之上，并与C＃，Visual Basic和F＃中的异步语言支持集成。 TDF缺少按键（如SSIS）和基于时间的窗口（在Rx中可用）的连接/合并。
有一个 .NET Core Worker Service，它具有用于执行并行过程的数据流模式。它有TransformBlock和ActionBlock。 在运行 Worker 进程时，TransformBlock 和 Action...
C# Dotnet Core 数据流模式单元测试不等待操作完成
有一个 Dotnet 核心工作服务，它具有用于执行并行过程的数据流模式。它有TransformBlock和ActionBlock。 运行 Worker 进程时，TransformBlock 和
Parallel.ForEach 与 ActionBlock
对于给定的 MaxDegreeOfParallelism 和需要处理的固定数量的对象（即在它们上执行某些代码），Parallel.ForEach 和 ActionBlock 似乎是相同的
我正在学习数据流基础知识。 这是一个代码示例，对我来说看起来正确，但不起作用。 它不会返回结果整数值，而是冻结。 根据我的理解，这是因为完成...
如果排队的项目数小于BatchSize，如何在超时后自动调用TriggerBatch？
使用 Dataflow CTP（在 TPL 中） 如果超时后当前排队或推迟的项目数量小于 BatchSize，是否有办法自动调用 BatchBlock.TriggerBatch？ 还有
如果在不同线程中使用同一个对象，DataFlow 对象是否需要锁定
我在不同的线程中使用相同的数据流对象。 是否必须在数据流对象上使用锁，或者对象是否自动线程安全？ 例如： // 定义数据流对象
IHostedService 中的 Rabbit MQ 线程安全
我有三个 C# 类。 rabbitmq 订阅者有一个 connect() 方法、subscribe(Action messageHandler) 方法和一个 Ack(ulong messageId) 方法。此类被实例化为单例并通过...
为什么我的 ActionBlock 在没有设置的情况下会进入完成状态？
一时百思不得其解，想不出什么合理的解释。也许这里有人有解释。 设置： 我有一个生成很多工作项的类，要用 Actio 计算...
我试图理解TPL Dataflow中的异常处理，以便能够有效地处理错误。在我的评论1.下面，我期望捕获一个AggregateException，但一切都停止了......。
我写了一个方法来实现TPL ActionBlock，它将做一个函数来找到我正在Posting到块中的元素的XPath。我从一个实时应用程序中发送元素（...
我正在使用TPL Dataflow建立一条流水线。这个流水线在逻辑上应该做到以下几点。首先处理多个数据项--比如说是pollingBlock。在满足某些条件的情况下...
通过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操作（带限制）的提示，并通过限制异步任务进行了回答。我拆分了加载...