c++ - 管道架构

Question

在 OOP 方面如何实现 Pipeline 架构？

为了更好地解释我自己：

Source -> Filter -> Filter -> Filter -> Sink

假设我们有一个名为 PipelineStage 的基类。如何实现过滤器、源和接收器？

我有两个想法：

带有 ISource 和 ISink 接口

使用 Filter 的 Sink 和 Source 子类化

Answer 1

Source 和 Sink 似乎是过度的和复杂的整体结构。它们不需要是过滤器。

源就是源，这就是它的功能。如果知道从哪里获取数据以及如何将其传递到管道。不要强迫他成为别的东西，而是源头。

Sink 也是如此。

如果您想要验证输入的内容 - 添加一个额外的验证过滤器。

Answer 2

请看一下责任链模式。您可以使用构建器模式根据一些规则构建链，一旦构建，触发源，它通过链处理直到结束（Sink）。断链问题很常见，但您仍然可以有办法处理它。