Lines Matching refs:q

49     static void push(Q& q, T&& t) {  in push()
50 q.push(std::forward<T>(t)); in push()
56 void QueuePushHelper<false>::push( Q& q, T&& t ) { in push() argument
57 q.push(std::move(t)); in push()
92 void examine( const QueueType& q, const std::vector<typename QueueType::value_type>& vec_sorted ) { in examine() argument
93 QueueType q1(q), q2(q); in examine()
235 void push_selector(Q& q, E e, std::size_t i) { in push_selector() argument
237 case 0: q.push(e); break; in push_selector()
238 case 1: q.push(std::move(e)); break; in push_selector()
239 case 2: q.emplace(e); break; in push_selector()
249 tbb::concurrent_priority_queue<T, C>* q; variable
255 : n_thread(n), my_min(min), my_max(max), q(cpq) {} in FillBody()
261 push_selector(*q, elem, i); in operator()
271 tbb::concurrent_priority_queue<T, C>* q; member
278 : my_max(max), q(cpq) {} in EmptyBody()
282 if (q->try_pop(last)) { in operator()
284 while(q->try_pop(elem)) { in operator()
296 tbb::concurrent_priority_queue<T, C>* q; variable
302 : q(cpq) {} in FloggerBody()
307 push_selector(*q, elem, i); in operator()
308 q->try_pop(elem); in operator()
317 tbb::concurrent_priority_queue<T, C> q(0); in test_parallel_push_pop()
318 FillBody<T, C> filler(n, t_max, t_min, &q); in test_parallel_push_pop()
319 EmptyBody<T, C> emptier(t_max, &q); in test_parallel_push_pop()
324 qsize = q.size(); in test_parallel_push_pop()
325 REQUIRE_MESSAGE(q.size() == n * MAX_ITER, "Failed concurrent push size test"); in test_parallel_push_pop()
326 REQUIRE_MESSAGE(!q.empty(), "Failed concurrent push empty test"); in test_parallel_push_pop()
330 REQUIRE_MESSAGE(q.size() == 0, "Failed pop empty test"); in test_parallel_push_pop()
335 tbb::concurrent_priority_queue<T, C> q(0); in test_flogger()
336 utils::NativeParallelFor(n, FloggerBody<T, C>{&q}); in test_flogger()
337 REQUIRE_MESSAGE(q.empty(), "Failed flogger empty test"); in test_flogger()
338 REQUIRE_MESSAGE(!q.size(), "Failed flogger size test"); in test_flogger()