tpl-dataflow 相关问题

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

ActionBlock B从不接收TransformBlock A返回的项目

我的C＃/ WPF应用程序中的TPL数据流网格存在问题。第一个输入项（称为“作业”）始终贯穿整个链，直到最后一个TPL块。但是剩下的工作...

c# task-parallel-library tpl-dataflow

回答 1 投票 1

存储不同通用类型的列表

我知道这是一个经常讨论的话题，因为我发现很多帖子都在谈论这个话题。不幸的是，它们似乎都无法解决我的问题，或者是因为我不了解解决方案，还是...

c# generics tpl-dataflow

回答 1 投票 1

TPL数据流，仅当所有源数据块都完成时才保证完成

如何在两个变换块都完成后重新编写代码完成的代码？我以为完成意味着将其标记为完成并且“出队列”为空？公共Test（）{...

c# concurrency task-parallel-library tpl-dataflow

回答 5 投票 25

创建将单个输入转换为多个输出的TPL数据流TransformBlock

我正在基于数据流模式开发一个项目。为此，我使用来自.NET的TPL Dataflow库。我是最近才了解这个图书馆的，所以我仍然是一个新手，几乎一无所知。 ...

c# .net web-scraping tpl-dataflow

回答 1 投票 0

如何为同时运行的多个ActionBlock设置CPU优先级？

我有一堆ActionBlocks，每个块都做不同的事情。大数据处理数据，并由TransformBlock连续地馈送数据。其他3个ActionBlock只需在3个文本文件中编写行（...

c# tpl-dataflow thread-priority

回答 1 投票 0

一个ActionBlock可以包含一个状态吗？

我正在编写使用TPL数据流的应用程序。我正在尝试配置一个动作块以写入数据库。但是，我需要此操作块才能对...

c# lambda task-parallel-library tpl-dataflow

回答 1 投票 0

即使调用“ Complete（）”，C＃TransformBlock也不会运行。

（x =＆...

c# transform hang tpl-dataflow complete

回答 1 投票 0

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

我正在使用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-dataflow 相关问题

最新问题