Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
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
下游块中的 TPL 数据流和异常处理
我有以下伪代码 var queue new BufferBlock
c
Exception
taskparallellibrary
tpldataflow
TPL 数据流和 Akka.net 有什么区别?
我曾使用过 TPL 数据流 真的很喜欢它 我从我的 java scala 朋友那里多次听到 Akka 这个词 所以我尝试阅读相关内容 发现 akka 也有一个 net 端口 伟大的 当我继续阅读 akka 是什么时 我惊讶地发现它听起来和
NET
akka
taskparallellibrary
Actor
tpldataflow
TPL Dataflow,Post() 和 SendAsync() 之间的功能区别是什么?
我对通过 Post 或 SendAsync 发送项目之间的区别感到困惑 我的理解是 在所有情况下 一旦一个项目到达数据块的输入缓冲区 控制权就会返回到调用上下文 对吗 那么为什么我需要 SendAsync 呢 如果我的假设不正确 那么我想知
c
concurrency
taskparallellibrary
messagepassing
tpldataflow
.NET 中的并行抓取
我工作的公司运营着数百个非常活跃的网站 它决定建立一个搜索引擎 我的任务是编写爬虫 一些网站在旧硬件上运行 无法承受太多惩罚 而另一些网站则可以处理大量并发用户 我需要能够说对站点 A 使用 5 个并行请求 对站点 B 使用 2 个并行请求
c
NET
taskparallellibrary
asyncawait
tpldataflow
1
2
3
»