Lines Matching refs:limiter_node
91 tbb::flow::limiter_node<T> &my_lim;
94 put_body( tbb::flow::limiter_node<T> &lim, std::atomic<int> &accept_count ) : in put_body()
109 tbb::flow::limiter_node<T> &my_lim;
112 put_dec_body( tbb::flow::limiter_node<T> &lim, std::atomic<int> &accept_count ) : in put_dec_body()
130 void test_puts_with_decrements( int num_threads, tbb::flow::limiter_node< T >& lim , tbb::flow::gra… in test_puts_with_decrements()
158 tbb::flow::limiter_node< T > lim(g, i); in test_parallel()
173 tbb::flow::limiter_node< T > lim(g, i); in test_parallel()
175 tbb::flow::limiter_node< T > lim_copy( lim ); in test_parallel()
194 tbb::flow::limiter_node< T > lim(g, i); in test_serial()
207 tbb::flow::limiter_node< T > lim(g, i); in test_serial()
287 tbb::flow::limiter_node<int> lim_node(g, _nparallel); in test_multifunction_to_limiter()
315 tbb::flow::limiter_node<int> ln(g,2); in test_continue_msg_reception()
339 limiter_node<int, int> limit(g,2); //threshold of 2 in test_reserve_release_messages()
378 tbb::flow::limiter_node<int, int> limit(g, threshold); in test_decrementer()
400 tbb::flow::limiter_node<int, long long> limit2(g, threshold2); in test_decrementer()
418 tbb::flow::limiter_node<int, long long> limit3(g, threshold3); in test_decrementer()
441 tbb::flow::limiter_node<int> ln(g, try_put_num); in test_try_put_without_successors()
481 <msg_t, tbb::flow::limiter_node<msg_t, msg_t>>(messages_for_follows, 1000); in test_follows_and_precedes_api()
483 <msg_t, tbb::flow::limiter_node<msg_t, msg_t>>(messages_for_precedes, 1000); in test_follows_and_precedes_api()
494 limiter_node<int> l0(g, 100); in test_deduction_guides()
497 limiter_node l1(follows(br), 100); in test_deduction_guides()
498 static_assert(std::is_same_v<decltype(l1), limiter_node<int>>); in test_deduction_guides()
500 limiter_node l2(precedes(br), 100); in test_deduction_guides()
501 static_assert(std::is_same_v<decltype(l2), limiter_node<int>>); in test_deduction_guides()
504 limiter_node l3(l0); in test_deduction_guides()
505 static_assert(std::is_same_v<decltype(l3), limiter_node<int>>); in test_deduction_guides()
519 tbb::flow::limiter_node<int, int> blockingNode{ graph, 1 }; in test_decrement_while_try_put_task()