tpl-dataflow

3热度

1回答

有没有办法确定BroadcastBlock<T,T>是否链接到任何数据块？如何检查是否有任何下游数据块从BroadcastBlock链接到？

3热度

2回答

在TPL数据流中，是否可以在块创建之后但使用之前更改DataflowBlockOptions？

...并使其生效？我想推迟设置ExecutionDataflowBlockOptions.SingleProducerConstrained属性，直到我准备好将网络连接在一起。（因为我想分开创建块和它们的语义，将网络连接在一起并与其语义相关联。）但是据我所知，只能在创建块时设置ExecutionDataflowBlockOptions（例如，对于TransformBlock，Transfor

2热度

1回答

直接指定Action或Task-Generator与TPL数据流ActionBlock之间有什么区别？

指定Action直接或Func<Task>与.NET TPL数据流ActionBlock有什么区别？直接行动： new ActionBlock<Message[]>(x => DoSomething(x)) 任务： new ActionBlock<Message[]>(x => Task.Run(() => DoSomething(x))) 我想了解关于并行执行（MaxDegreeOfP

3热度

2回答

微软TPL数据流 - 同步处理关联请求

我为标题提前道歉，但它是描述行为的最好的想法。要求是处理消息总线的请求。请求可能与相关或分组这些请求的id相关。我想要的行为是请求流同步处理关联ID。但是，不同的ID可以异步处理。我正在使用concurrentdictionary来跟踪正在处理的请求和linkto中的谓词。这是假设提供相关请求的同步处理。但是，我得到的行为是第一个请求得到处理，第二个请求被丢弃。我附上了来自控制台应

6热度

1回答

TPL Dataflow如何删除块之间的链接

我想知道。我怎样才能删除块之间的链接？换一种说法。我想得到LinkTo的反面。我想写一个基于tlp数据流的记录器。我写了这个接口，并希望在需要时删除ILogListener的订阅。 public interface ILogManager { void RemoveListener(ILogListener listener); }

3热度

2回答

如何在TPL Dataflow中分支逻辑？

如果这是一个简单的问题，那么我对TPL数据流很熟悉，所以请原谅我。我有一个输入缓冲区块，需要一个基类。我如何从那里分支到基于派生类型的块？例如： var inputBlock = new BufferBlock<EventBase>(); //if EventBase is Meeting then go to block X //if EventBase is Appointment th

0热度

1回答

TPL数据流bufferblock消息发送定时器

我想建立在this问题上。到目前为止，我已经得到了并行处理作业的方法。我在一个控制台应用程序中运行这个。我从数据库中获得50个工作，使用TPL DataFlow处理它们，到目前为止这么好。但是我意识到，如果有一项工作需要一小时的时间才能完成，其余工作将在15分钟内完成，那么控制台应用程序将继续工作一个小时而不处理任何其他工作。我无法将其更改为Windows服务，因此我必须使控制台应用程序处理新作

3热度

1回答

使用PCL'TPL Dataflow'的项目在编译时不会编译.NET 4.5.2

我正在使用Windows 7 Pro x64 SP1和Visual Studio 2012 Update 4.我无法让我的VB.NET WPF项目编译当使用TPL Dataflow包和.NET 4.5.2时。我创建了一个基地项目什么也没有，除了这个代码和编译只针对x64： Imports System.Threading.Tasks.Dataflow Class MainWindow

0热度

1回答

如何做EF异步'分页'处理选择结果

我正在写一些东西，从SQL服务器加载到azure队列的记录。问题是，选择结果中的项目数量可能非常大，因此我想在数据仍在检索时开始排队。我试图利用EF6（异步），所有异步方法和和TPL并行排队。所以，我有： // This defines queue that Generator will publsh to and // QueueManager wil read from. Mo

0热度

1回答

基于串行通信的仪器控制应用程序的体系结构建议

我刚刚开始了一个项目来控制通过RS-232串行端口进行通信的工业仪器。波特率限制在9600 ...相当慢。该仪器可在两种模式下操作 - 轮询，其中该PC机发送的请求，并且该仪器与数据回复;或连续的，仪器发送恒定流数据。数据需要从ASCII转换为浮点数并绘制。我与使用一个串口DataRecieved事件样本程序最初的实验是不吉利......这是很容易得到用户界面成为下从仪器连续发送不响应。我看过