Lines Matching refs:continue_msg
107 typedef std::tuple<oneapi::tbb::flow::continue_msg, chopstick, chopstick> join_output;
110 typedef oneapi::tbb::flow::function_node<oneapi::tbb::flow::continue_msg,
111 oneapi::tbb::flow::continue_msg>
113 typedef oneapi::tbb::flow::function_node<join_output, oneapi::tbb::flow::continue_msg>
115 typedef oneapi::tbb::flow::multifunction_node<oneapi::tbb::flow::continue_msg, join_output>
141 void forward(const oneapi::tbb::flow::continue_msg &in,
158 oneapi::tbb::flow::continue_msg operator()(oneapi::tbb::flow::continue_msg /*m*/) { in operator ()() argument
160 return oneapi::tbb::flow::continue_msg(); in operator ()()
170 oneapi::tbb::flow::continue_msg operator()(const join_output &in) { in operator ()()
172 return oneapi::tbb::flow::continue_msg(); in operator ()()
182 void operator()(const oneapi::tbb::flow::continue_msg &in, in operator ()()
195 void philosopher::forward(const oneapi::tbb::flow::continue_msg & /*in*/, in forward() argument
204 oneapi::tbb::flow::continue_msg()); //start thinking again in forward()
238 typedef oneapi::tbb::flow::queue_node<oneapi::tbb::flow::continue_msg> thinking_done_type;
312 think_nodes[i]->try_put(oneapi::tbb::flow::continue_msg()); in main()