如何从 tbb::flow::graph 中删除/取消消息？

Question

我构建了一个tbb::flow::graph由几个function_node对象组成的对象。在执行期间，我将多条消息传递到图中（从 ~10 到 ~100000）。有时其中一个节点会抛出异常。如果是这种情况，整个图的执行将被取消，这意味着所有消息都将被丢弃。但是，我的消息是相互独立的，我不希望它们的执行被停止。

我可以直接在节点内部捕获异常，但是当发生这种情况时，对消息的进一步处理将没有意义。

所以我的问题是：如何从图中取消或删除单个消息而不取消图中已经存在的其他消息的执行？

Answer 1

对于可能抛出异常的节点，使用multifunction_node代替function_node。a 的主体函子multifunction_node接受其输出端口的元组，并且与 不同function_node，应该明确地将消息放入这些端口。因此multifunction_node可以丢弃/丢弃消息，或为每个输入创建多个输出。

请注意，多个输出端口multifunction_node不会为每个后继者假设一个单独的端口。您可以拥有一个输出端口并将所有后继端口连接到它；输出消息将以相同的方式广播给每个后继者function_node。然而，多个输出端口允许multifunction_node不受单一类型输出的限制，使其成为流图中复杂消息分发的非常灵活的工具。

有关不同节点的消息处理的更多信息，请参阅TBB 文档中的单推送与广播推送、其他流图概念和节点行为策略。