如何 remove/cancel 来自 tbb::flow::graph 的消息？
How to remove/cancel a message from tbb::flow::graph?
我构建了一个 tbb::flow::graph，它由几个 function_node 对象组成。在执行期间，我将多条消息传递到图中（从 ~10 到 ~100000）。有时其中一个节点会抛出异常。如果是这种情况，整个图的执行将被取消，这意味着所有消息都将被丢弃。但是，我的消息是相互独立的，我不希望它们的执行被停止。
我可以直接在节点内捕获异常，但是当发生这种情况时，对消息的进一步处理就没有意义了。
所以我的问题是：如何取消或删除图中的单个消息而不取消图中已有的其他消息的执行？
对于可能抛出异常的节点，使用multifunction_node代替function_node。 multifunction_node 的主体仿函数接受其输出端口的元组，并且与 function_node 不同，应该明确地将消息发送到这些端口。因此 multifunction_node 可以 discard/drop 消息，或为每个输入创建多个输出。
请注意，multifunction_node 的多个输出端口不会为每个后继端口假定一个单独的端口。您可以有一个输出端口并将所有后继端口连接到它；输出消息将以与 function_node 相同的方式广播给每个后继者。然而，多个输出端口允许 multifunction_node 不受单一类型输出的限制，使其成为在流程图中进行复杂消息分发的非常灵活的工具。
有关不同节点处理消息的更多信息，请参阅 TBB 文档中的 single-push vs. broadcast-push, other flow graph concepts, and the node behavior policies。
我构建了一个 tbb::flow::graph，它由几个 function_node 对象组成。在执行期间，我将多条消息传递到图中（从 ~10 到 ~100000）。有时其中一个节点会抛出异常。如果是这种情况，整个图的执行将被取消，这意味着所有消息都将被丢弃。但是，我的消息是相互独立的，我不希望它们的执行被停止。
我可以直接在节点内捕获异常，但是当发生这种情况时，对消息的进一步处理就没有意义了。
所以我的问题是：如何取消或删除图中的单个消息而不取消图中已有的其他消息的执行？
对于可能抛出异常的节点，使用multifunction_node代替function_node。 multifunction_node 的主体仿函数接受其输出端口的元组，并且与 function_node 不同，应该明确地将消息发送到这些端口。因此 multifunction_node 可以 discard/drop 消息，或为每个输入创建多个输出。
请注意，multifunction_node 的多个输出端口不会为每个后继端口假定一个单独的端口。您可以有一个输出端口并将所有后继端口连接到它；输出消息将以与 function_node 相同的方式广播给每个后继者。然而，多个输出端口允许 multifunction_node 不受单一类型输出的限制，使其成为在流程图中进行复杂消息分发的非常灵活的工具。
有关不同节点处理消息的更多信息，请参阅 TBB 文档中的 single-push vs. broadcast-push, other flow graph concepts, and the node behavior policies。