-
NetworkStream线程瓶颈 测试1:TCP I 测试2:TCP O 测试3:TCP IO 测试4:本地处理测试5:生产测试
我一直在一个服务器上工作,该服务器接收来自另一台服务器的请求,计算该值,然后通过TCP返回结果 -
为什么我的TPL数据流操作块无法并行执行?
我正在尝试并行执行一些Web请求,但是由于某种原因,它们都一次又一次地同步运行,所以我不知道为 -
向所有使用者发送TPL数据流重复消息
我目前正在使用WPF和TPL Dataflow编写一个应用程序,该应用程序应该执行以下操作: <ol> <li>将所有文 -
遍历TPL Dataflow块的正确方法是什么?
我读过某处可以循环TPL Dataflow块的信息,但是我还没有看到一个清楚的例子说明如何处理此问题。我的 -
取消数据流ActionBlock中的特定任务
经过一整天的搜索,我遇到了一条评论,即取消TPL数据流是一种取消整个块而不是单个任务/项目的方法 -
两分支数据流网络未完成
此数据流网络具有单个分支,并产生具有正确结果的正确文本输出。为什么没有完成? <pre><code> -
BufferBlock在OutputAvailableAsync上被阻塞
我是使用TPL的新手。我已经能够在BufferBlock上实现简单的post / receive事务,但是当我尝试进行异步操作时 -
具有TCP NetworkStream的TPL数据流
<a href="https://docs.microsoft.com/en-us/dotnet/standard/parallel-programming/dataflow-task-parallel-library" rel="nofollow noreferrer" -
动作块可以包含状态吗?
我正在编写一个使用TPL数据流的应用程序。我正在尝试配置一个动作块以写入数据库。 但是,我 -
调用Complete函数后,不执行C#TransformBlock
我有以下代码段: <pre><code>static void Main(string[] args) { var printResult = new ActionBlock<int>(x => { -
即使调用“ Complete()”,C#TransformBlock也不会运行
我有此代码段,尝试使用TransformBlock启动代码执行,如下所示: <pre><code><a id="user" href="#&# -
C#:等待TransformBlock.Completion挂起而没有响应
我有这个: <pre><code>public static async Task Main(string[] args) { try { var block = new TransformBlock<in -
创建一个TPL数据流TransformBlock,将单个输入转换为多个输出
我正在基于Dataflow Pattern开发一个项目。为此,我使用来自.NET的TPL Dataflow库。 我是最近才了解这个 -
存储不同的通用类型的列表
我知道这是一个经常讨论的话题,因为我发现很多帖子都在谈论这个话题。不幸的是,它们似乎都无法 -
动作块B从不接收TransformBlock A返回的项目
我的C#/ WPF应用程序中的TPL Dataflow网格出现问题。第一个输入项(称为“作业”)始终贯穿整个链,直 -
使用TPL ActionBlock,我可以在作业完成后添加新项目吗?
我在我的应用程序中使用TPL <code>ActionBlock</code>来实现并行性。 我有一个应用程序,它将根据用户 -
通过BufferBlock产生的反压不起作用。 (C#TPL数据流) 如果您在看这个问题,您需要记住ActionBlock也有自己的输入缓冲区。完成传播需要在链接级别上明确定义。
典型情况:<strong>生产者速度快,消费者消费缓慢,需要降低生产者速度</strong>。<br/> 示例代码无法正常 -
ActionBlock在我希望完成之前似乎已完成
我有<code>ActionBlock</code>作为课程的一部分: <pre><code>private readonly ActionBlock<QueueMessage> block; </code> -
如何获取异常的上下文
我正在将<code>TaskParallelLibrary DataFlow</code>与Stephen Cleary(<a href="https://github.com/StephenCleary/Try" rel="nofollow nor -
取消TPL数据流块的正确方法
我正在使用<code>TPL</code>块来执行可能被用户取消的操作: 我想出了两个选择,首先,我取消整个块,但 -
如何以(线程)安全的方式跟踪TPL管道中的故障项
我正在将TPL管道设计与Stephen Cleary的<a href="https://github.com/StephenCleary/Try" rel="nofollow noreferrer">Try library</a> -
如何在转换期间使用嵌入的死区时间来实现TransformBlock?
背景:我正在尝试解决<a href="https://stackoverflow.com/questions/17469689/retry-policy-within-itargetblocktinput">embedding a r -
如何在ASP NET Core中集成TPL数据流
您最近对<code>TPL Dataflow</code>充满兴趣,我想将其集成到我的<code>ASP .NET Core</code>应用程序中。 我想将其 -
无法运行TPL Dataflow管道
我正在尝试使用<code>TPL Dataflow</code>创建一个管道,可以在其中将消息存储在批处理块中,并且一旦达到 -
如何使用.Net TPL DataFlow或反应性扩展来同时处理发布到RabbitMQ的动态消息?
对于我的应用程序体系结构,我有一个API,可根据收到的请求将消息发布到RabbitMQ。 Windows服务充当RabbitM -
我应该选择与任务并行库一起使用的简单Dictionary或ConcurrentDictionary 数据流订购 ImmutableDictionary
这是一个简化的场景-用户想下载并处理一些数据: <pre><code>private ConcurrentDictionary<int, (string path, str -
如何使用Polly停止发布到TPL管道的工作
我正在探索如何实现<code>TPL DataFlow</code>管道的不同方法。请按照代码示例中的所有注释来理解我的问题 -
为什么Stream.CopyTo不直接写入文件?
此操作块连接到具有签名<code>var getStream = new TransformBlock<FileChunk, Tuple<Task<HttpResponseMessage>, FileChu -
阻止BroadcastBlock在LinkTo上发送缓冲的消息
给一个<code>BroadcastBlock</code>缓冲区中有一条消息,是否可以防止将该消息发送到新链接的目标?例如:</ -
任务并行数据流中一个块与多个单线程目标块中并行的原因
创建<code>n</code>个数量<code>ITargetBlock<T></code>个不具有并行性的工作人员与一个<code>ITargetBlock<T></