tpl-dataflow 相关问题

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

我如何等待我的自定义数据流块完成？

我正在使用ITargetBlock，并且已成功创建了一个自定义数据流块。但是，我不能全神贯注于实现“完成”任务。我目前将其定义为：...

c# async-await task-parallel-library tpl-dataflow

回答 1 投票 1

[BufferBlock在OutputAvailableAsync上被阻塞

我是不熟悉TPL的人。我已经能够在BufferBlock上实现简单的post / receive事务，但是当我尝试进行异步操作时，我会挂起。这是我的简化版本...

vb.net asynchronous async-await task-parallel-library tpl-dataflow

回答 1 投票 0

两分支数据流网络未完成

此数据流网络具有单个分支，并产生具有正确结果的正确文本输出。为什么没有完成？ //连接多个块//源-> ...

c# task-parallel-library tpl-dataflow

回答 1 投票 2

WPF MVVM和TPL数据流中的进度条

我正在按照MVVM模式在WPF应用程序中使用TPL数据流。我有一个TransformBlock 和一个ActionBlock ，并且我像这样链接它们：transformBlock ....

c# wpf mvvm task-parallel-library tpl-dataflow

回答 3 投票 5

TPL DataFlow处理异常的正确方法

我在使用TPL DataFlow管理队列（数据库）并将工作重定向到网格计算服务的Windows服务中遇到问题。某一时刻BufferBlock停止释放任务，然后我...

c# .net task-parallel-library tpl-dataflow

回答 1 投票 0

通过IEnumerable和TPL数据流传输数据

我正在从上游API获取项目，这很慢。我试图通过使用TPL Dataflow创建多个连接并将它们组合在一起来加快速度，就像这样；类Stuff {int Id {...

c# enumerate tpl-dataflow

回答 2 投票 1

为什么在SelectMany中引发异常后，我的进程仍然有效，而类似的rx运算符中的异常会导致未处理的异常？

这里是一个示例程序，它对控制台输入进行了两次订阅（此处可观察到的源不相关）。在第一个订阅中，它使用Observable.SelectMany；在第二个订阅中，它使用类似的...

.net system.reactive unhandled-exception tpl-dataflow

回答 2 投票 1

如何以同步方式合并两个TPL DataFlow管道？

我想编写一个评估两个传感器的传感器数据的应用程序。两个传感器都将其数据发送到Package对象中，Package对象将被拆分为Frame对象。包本质上是一个元组

task-parallel-library tpl-dataflow

回答 1 投票 1

如何停止传播异步流（IAsyncEnumerable）

我有一个接受IAsyncEnumerable作为参数，并还返回IAsyncEnumerable的方法。它为输入流中的每个项目调用Web方法，并将结果传播到输出...

c# async-await tpl-dataflow c#-8.0 iasyncenumerable

回答 2 投票 1

TPL数据流，异常块故障处理程序不传播

我使用的是TPL数据流块来处理消息流。我的数据流网络由两个块，一个BufferBlock和ActionBlock的，与所述操作块被定义为：...

c# task-parallel-library tpl-dataflow

回答 1 投票 0

相当于Parallel.For的localInit和localFinally在MaxDegreeOfParallelism> 1时在TPL Dataflow块中使用

我有一个TransformBlock 有MaxDegreeOfParallelism = 6.我也确定了Func 传递给块的构造函数（为每个...执行）

c# task-parallel-library tpl-dataflow

回答 3 投票 0

TPL BufferBlock.ReceiveAsync两次接收相同的项目

我有这样的BufferBlock设置。 _inputQueue = new BufferBlock （new DataflowBlockOptions {BoundedCapacity = 1，CancellationToken = cancellationToken，EnsureOrdered = ...

c# task-parallel-library azure-service-fabric tpl-dataflow bufferblock

回答 1 投票 0

C＃DataFlow：等待ConcurrentExclusiveSchedulerPair启动的所有任务完成

我有一个要执行的操作列表，可以在用户交互时取消。很简单，但ConcurrentExclusiveSchedulerPair .Completion永远不会完成。这是一个例子：静态......

c# asynchronous task-parallel-library tpl-dataflow

回答 1 投票 0

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

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

c# task-parallel-library tpl-dataflow

回答 1 投票 3

TPL Dataflow块消耗所有可用内存

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