System.Reactive基础——使用窗口和缓冲来分组事件数据

问题 一种情况是,假设有一个事件序列,需要在收到事件时将他们分组,比如需要响应成对的输入。另一种情况是,假设需 […]

System.Reactive基础——向上下文发送通知

问题 System.Reactive最大限度地实现了无差别对待不同的线程。无论当前是什么线程,它都会在其中发送 […]

System.Reactive基础——转换.Net事件

System.Reactive把时间当做陆陆续续传来的数据序列。可以把System.Reactive视作LIN […]

数据流基础——创建自定义块

问题 假设你想把可复用的逻辑放到自定义的数据流块中。这样一来,便可以创建更大的块,使其包含更复杂的逻辑 解决方 […]

数据流基础——块的并行处理

问题 假设需要在数据流网格中执行并行处理 解决方案 在默认情况下,没个数据流块彼此独立。当关联两个块时,他们会 […]

数据流基础——块的节流

问题 假设在数据流网格中存在分叉场景,而数据需要以负载均衡的方式流动。 解决方案 在默认情况下,当块生成输出数 […]

数据流基础——块的解耦

问题 假设在执行处理时,需要动态地变更数据流的结构,这种高级场景极为罕见 解决方案 可以随时关联或解耦数据流块 […]

数据流基础——传播错误

问题 假设需要对数据流网格中可能出现的错误做出响应 解决方案 如果传递至数据流块的委托抛出异常,则该快会进入错 […]

数据流基础——关联的块

TPL数据流是一个强大的库,通过它可以创建网格或管道,然后异步发送数据。数据流的代码具有非常明显的声明式风格: […]

并行编程基础——PLINQ

问题 假设需要对数据序列执行并行处理,来生成另一个数据序列或者对该数据求和。 解决方案 IEnumerable […]