这个问题困扰了我几个星期，但我太急于事后明智地解决它。我终于向急切的客户提供了一个快速而肮脏的解决方案，以缓解他脆弱的神经(结果也是我的)。我现在终于抽出时间用自由的头脑来审视这个问题。
基本上，我面临着尽可能快地(<5 毫秒)处理同步数据(时间顺序序列)的挑战。在尝试了很多 Rube-Goldberg 风格的设计之后，例如有序的线程池和涉及并行工作队列的混合解决方案以及其他不可靠的牵强附会的想法，一个彻底的动手工作证明坚持一个普通的'旧到目前为止，单线程链进程是数据完整性和性能的最佳选择。
但是，在应用程序底部的某个位置，这达到了一定的限制。我需要以并行方式向不同的处理器广播数据。这就是我再次开始头痛的地方。 当我让数据集线器(见下文)以异步方式(通过线程和二进制环形缓冲区)向处理器发送数据时，接收方以乱序接收数据，数据顺序被破坏。
所以我正在寻找一种以并行方式向所有处理器发送数据并保持顺序的方法。我的另一个问题是异步性:如果数据中心的 SendEvent 委托(delegate)被进程的 Receive 方法以普通的经典方式订阅(通过 += ) ，这将如何表现？
首先，我不希望订阅被称为“一个接一个”。我确信有一种方法可以将其并行化。其次，最重要的是，我当然不希望处理器 A 在完成其工作之前锁定整个链。
所以这是伙计们。长话短说，我想找到一种明智的方法来继续向处理器发送数据，而无需等待数据被处理，但同时我需要每个数据处理器以有序的方式接收数据。这听起来可能不相容，但我确信有一种聪明且非常简单的方法可以做到这一点(但我深入了解这个我真的很困惑，这就是为什么我请求你的帮助，好人)
最佳答案
如果您谈论的是一台机器，您需要在其中将有序系列分发到同一台机器上的所有处理器，我会使用 Data Hub，继续您的单线程想法，入队串行到N个私有(private)队列(相对较快，所以我不用担心阻塞，而且你知道该项目已排队到所有 em> 队列)。
这些私有(private)队列中的每一个都只允许从一个且唯一的处理器出队。可能较慢的“Data Hub --> Processors”将被并行调用，但不会像您所说的那样阻塞整个链，因为...
然后您可以配置 1 个处理器/队列/线程(易于管理)或 1 个队列/N 个队列/类似的无状态处理器(这将需要额外的下游工作来进行重新排序)。
在更加分布式的系统(例如多机)中，您通常有类似Data Hub 的东西向消息传递“主题”发送消息，然后让消息传递基础结构发送给所有消费者。
关于c# - 混合异步/同步架构，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/11507438/