Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何强制 ActionBlock 快速完成
根据文档 https learn microsoft com en us dotnet api system threading tasks dataflow actionblock 1 completion view netcore 3
c
Cancellation
tpldataflow
在 TPL Dataflow 中,是否可以在创建块之后但使用之前更改 DataflowBlockOptions?
有效果吗 我想推迟设置 ExecutionDataflowBlockOptions SingleProducerConstrained 属性 直到我准备好将网络链接在一起 因为 我想将创建块及其语义与将网络及其语义链接在一起分开 但据我所知
c
NET
taskparallellibrary
tpldataflow
ActionBlock 可以包含状态吗?
我正在编写一个使用 TPL 数据流的应用程序 我正在尝试配置一个操作块来写入数据库 但是 我需要这个操作块对其收到的第一条消息执行初始化步骤 请注意 我必须等待第一条消息 并且无法在操作块创建期间执行初始化 因此 我的操作块需要维护某种状态
c
Lambda
taskparallellibrary
tpldataflow
TPL Dataflow如何删除块之间的链接
我想知道 如何删除块之间的链接 换句话说 我想要与 LinkTo 相反 我想写一个基于 tlp 数据流的记录器 我编写了这个接口 并希望在需要时删除 ILogListener 的订阅 public interface ILogManager
c
taskparallellibrary
tpldataflow
TPL 数据流块下游如何获取源生成的数据?
我正在使用 TPL Dataflow 处理图像 我收到处理请求 从流中读取图像 应用多次转换 然后将生成的图像写入另一个流 Request gt Stream gt Image gt Image gt Stream 为此 我使用块 Buff
c
NET
taskparallellibrary
tpldataflow
异步任务、视频缓冲
我正在尝试理解 C 中的任务 但仍然遇到一些问题 我正在尝试创建一个包含视频的应用程序 主要目的是从文件中读取视频 我使用 Emgu CV 并通过 TCP IP 发送它以在板上进行处理 然后以流 实时 方式返回 首先 我是连续做的 所以 读
c
Asynchronous
videostreaming
task
tpldataflow
具有 BoundedCapacity 的 BufferBlock 和 ActionBlock 不使用最大 DOP
我有这个代码 var data new BufferBlock
c
NET
taskparallellibrary
asyncawait
tpldataflow
如何标记一个TPL数据流周期完成?
给定 TPL 数据流中的以下设置 var directory new DirectoryInfo C dev kortforsyningen dsm tiles var dirBroadcast new BroadcastBlock
c
NET
taskparallellibrary
tpldataflow
限制异步任务
我想运行一堆异步任务 并限制在任何给定时间可以等待完成的任务数量 假设您有 1000 个 URL 并且您只想一次打开 50 个请求 但是 一旦一个请求完成 您就会打开与列表中下一个 URL 的连接 这样 每次始终打开 50 个连接 直到 U
c
asyncawait
Semaphore
throttling
tpldataflow
tpl 数据流:固定缓冲区大小而不丢弃项目
在玩弄数据流之后 我遇到了一个新问题 我想限制所有块的输入队列 我的生产块 ActionBlock 正在快速创建 5000 个元素并将它们发布到广播块 因此 如果我将广播块的 BoundedCapacity 设置为 100 他会丢弃大量数据
c
NET
taskparallellibrary
tpldataflow
在哪里可以找到 4.0 的 TPL 数据流版本?
我正在寻找 NET 4 0 版本的 TPL 数据流库 Nuget 包有一个 4 0 版本的库 但它似乎针对 NET 4 5 我发现了对 4 0 版本的各种引用 例如在这个论坛中 http social msdn microsoft com
NET
net40
taskparallellibrary
NuGet
tpldataflow
如何恢复打乱的数据流管道的顺序?
我有一个数据流管道 由多个处理异构文档 XLS PDF 等 的块组成 每种类型的文档均由专门的人员处理TransformBlock 在管道的末端我有一个ActionBlock它接收所有处理后的文档 并将它们一一上传到网络服务器 我的问题是
c
taskparallellibrary
tpldataflow
明显的 BufferBlock.Post/Receive/ReceiveAsync 竞赛/bug
交叉发布到http social msdn microsoft com Forums en US tpldataflow thread 89b3f71d 3777 4fad 9c11 50d8dc81a4a9 http social msd
c
taskparallellibrary
asyncawait
dataflow
tpldataflow
C# TPL 数据流 - 完成不起作用
此代码永远不会到达最后一行 因为完成不会从 saveBlock 传播到 sendBlock 我究竟做错了什么 var readGenerateBlock new TransformBlock
c
taskparallellibrary
pipeline
tpldataflow
SingleProducerConstrained 和 MaxDegreeOfParallelism
在 C TPL 数据流库中 SingleProducerConstrained 是 ActionBlocks 的优化选项 当只有单个线程提供操作块时可以使用 如果一个区块只会被一个生产者在某个时间点使用 time 这意味着一次只有一个线程会
c
Multithreading
taskparallellibrary
tpldataflow
TPL 数据流与普通信号量
我需要制定一个可扩展的流程 该进程主要有 I O 操作和一些次要的 CPU 操作 主要是反序列化字符串 该流程在数据库中查询 url 列表 然后从这些 url 中获取数据 将下载的数据反序列化为对象 然后将部分数据保存到 crm 动态以及另
NET
taskparallellibrary
Semaphore
dataflow
tpldataflow
使用 Batchblock.Triggerbatch() 在 TPL 数据流管道中进行数据传播
在我的生产者 消费者场景中 我有多个消费者 每个消费者都向外部硬件发送一个操作 这可能需要一些时间 我的管道看起来有点像这样 BatchBlock gt TransformBlock gt BufferBlock gt 几个 ActionB
c
pipeline
throttling
tpldataflow
TPL 数据流:为什么 EnsureOrdered = false 会破坏此 TransformManyBlock 的并行性?
我正在研究 TPL 数据流管道 并注意到与排序 并行性相关的一些奇怪行为TransformManyBlocks 也可能适用于其他块 这是我要重现的代码 NET 4 7 2 TPL Dataflow 4 9 0 class Program s
c
taskparallellibrary
tpldataflow
System.Threading.Tasks.Dataflow 和 Microsoft.Tpl.Dataflow 之间有什么区别
有 2 个不同的官方 TPL Dataflow nuget 包 我很困惑选择应该使用哪一个 据我了解 System Threading Tasks Dataflow 版本比其他版本稍新 而且 System Threading Tasks D
c
tpldataflow
如何让异步流返回两个数据源
我有以下函数 它返回标准输出数据 作为异步流 该数据是由运行System Diagnostics Process 当前该方法中的所有内容都按预期工作 我可以用await foreach 循环 我得到由外部 exe 生成的每一行输出 priv
c
Asynchronous
tpldataflow
iasyncenumerable
1
2
3
»