フローグラフで単一メッセージを待機

説明

フローグラフで単一メッセージを待機#

説明 #

この機能により、フローグラフ内の受信ノードに新しい try_put_and_wait インターフェイスが追加されます。この関数は、メッセージをフローグラフへの入力として配置し、そのメッセージに関連するすべてのワークが完了するまで待機します。graph::wait_for_all は、入力メッセージに関係のないワークも含め、すべてのワークが完了するまで待機するため、try_put_and_wait は graph::wait_for_all を呼び出す場合と比べてレイテンシーを短縮できる可能性があります。

node.try_put_and_wait(msg) はノード上で node.try_put(msg) を実行し、msg でワークが完了するまで待機します。したがって、次の条件が当てはまります。

フローグラフ内の任意のノードによって開始されたタスクで、msg の操作または msg から計算されたその他の中間結果の処理を完了します。
msg から計算された中間結果はグラフ内のいづれのバッファーにも残りません。

警告

try_put_and_wait 呼び出しが無限に待機するのを防ぐには、最終結果はフローグラフによって自動的に消費されないため、フローグラフの最後でバッファーノードを使用てはなりません。

警告

現在、この機能では multifunction_node クラスと async_node クラスはサポートされていません。フローグラフにこれらのノードの 1 つを含めると、初期入力メッセージの計算が進行中であっても、try_put_and_wait が早期に終了する可能性があります。

API #

概要#

namespace oneapi { 
    namespace tbb { 
        template <typename Output, typename Policy = /*default-policy*/> 
        class continue_node { 
        public: 
            bool try_put_and_wait(const continue_msg& input); 
        }; // class continue_node 

        template <typename Input, typename Output = continue_msg, typename Policy = /*default-policy*/> 
        class function_node { 
        public: 
            bool try_put_and_wait(const Input& input); 
        }; // class function_node 

        template <typename T> 
        class overwrite_node { 
        public: 
            bool try_put_and_wait(const T& input); 
        }; // class overwrite_node 

        template <typename T> 
        class write_once_node { 
        public: 
            bool try_put_and_wait(const T& input); 
        }; // class write_once_node 

        template <typename T> 
        class buffer_node { 
        public: 
            bool try_put_and_wait(const T& input); 
        }; // class buffer_node 

        template <typename T> 
        class queue_node { 
        public: 
            bool try_put_and_wait(const T& input); 
        }; // class queue_node 

        template <typename T, typename Compare = std::less<T>> 
        class priority_queue_node { 
        public: 
            bool try_put_and_wait(const T& input); 
        }; // class priority_queue_node 

        template <typename T> 
        class sequencer_node { 
        public: 
            bool try_put_and_wait(const T& input); 
        }; // class sequencer_node 

        template <typename T, typename DecrementType = continue_msg> 
        class limiter_node { 
        public: 
            bool try_put_and_wait(const T& input); 
        }; // class limiter_node 

        template <typename T> 
        class broadcast_node { 
        public: 
            bool try_put_and_wait(const T& input); 
        }; // class broadcast_node 

        template <typename TupleType> 
        class split_node { 
        public: 
            bool try_put_and_wait(const TupleType& input); 
        }; // class split_node 
    } // namespace tbb 
} // namespace oneapi