| /oneTBB/test/conformance/ |
| H A D | conformance_concurrent_priority_queue.cpp | 347 q1.try_pop(ob); in test_move_support_in_push_pop()
357 q2.try_pop(o); in test_move_support_in_push_pop()
359 q2.try_pop(o); in test_move_support_in_push_pop()
361 q2.try_pop(o); in test_move_support_in_push_pop()
363 REQUIRE_MESSAGE(!q2.try_pop(o), "The queue should be empty"); in test_move_support_in_push_pop()
370 q3.try_pop(obj); in test_move_support_in_push_pop()
374 REQUIRE_MESSAGE(!q3.try_pop(obj), "The queue should be empty"); in test_move_support_in_push_pop()
485 qo.try_pop(e); in test_assignment_clear_swap()
492 qo.try_pop(e); in test_assignment_clear_swap()
519 REQUIRE_MESSAGE(q.try_pop(e), "Failed pop test"); in test_serial_push_pop()
[all …]
|
| H A D | conformance_concurrent_queue.cpp | 77 bool try_pop( T& dest ) { in try_pop() function in ConcQWithCapacity
78 base_type::try_pop( dest); in try_pop()
472 src_queue.try_pop(tmp_bar); in TestConstructors()
498 src_queue.try_pop(tmp_bar); in TestConstructors()
502 dst_queue5.try_pop(tmp_bar); in TestConstructors()
533 src_queue_ex.try_pop(tmp_bar_ex); in TestConstructors()
634 …bool try_pop( T& dest ) { return this->oneapi::tbb::concurrent_queue<T, test_allocator<T>>::try_po… in try_pop() function in ConcQPushPopWrapper
719 bool result = queue.try_pop(f); in TestPushPop()
1020 while (iq2.try_pop(e)) ; in TestAbort()
1064 while (iq4.try_pop(e)) ; in TestAbort()
[all …]
|
| /oneTBB/test/common/ |
| H A D | concurrent_priority_queue_common.h | 37 while(cpq.try_pop(element)) { in toVector()
68 REQUIRE((q2.empty() && !q2.size() && !q2.try_pop(elem))); in examine()
71 for (it1 = vec_sorted.rbegin(); q1.try_pop(elem); ++it1) { in examine()
86 for (it1 = vec_sorted.rbegin(); q1.try_pop(elem); ++it1) in examine()
282 if (q->try_pop(last)) { in operator()
284 while(q->try_pop(elem)) { in operator()
308 q->try_pop(elem); in operator()
|
| /oneTBB/examples/test_all/fibonacci/ |
| H A D | fibonacci.cpp | 129 while (!Q.try_pop(A)) in SerialQueueFib()
133 while (!Q.try_pop(B)) in SerialQueueFib()
296 while (!queue->try_pop(m1)) in operator ()()
298 while (!queue->try_pop(m2)) in operator ()()
319 bool result = Queue.try_pop(M); // get last element in ParallelPipeFib()
|
| /oneTBB/doc/main/tbb_userguide/ |
| H A D | Concurrent_Queue_Classes.rst | 11 ``try_pop``. The ``push`` operation works just like ``push`` for a
12 std::queue. The operation ``try_pop`` pops an item if it is available.
47 if( MyQueue.try_pop(item) ) {
|
| /oneTBB/test/tbb/ |
| H A D | test_concurrent_priority_queue.cpp | 167 REQUIRE_MESSAGE(pq.try_pop(elem), "Failed: pq is not functional"); in test_exceptions()
183 REQUIRE_MESSAGE(pq2.try_pop(elem), "Failed: pq is not functional"); in test_exceptions()
|
| H A D | test_concurrent_queue.cpp | 43 queue.try_pop(item); in operator ()()
97 bool b = q1.try_pop(tmp); in TestVectorTypes()
|
| H A D | test_concurrent_queue_whitebox.cpp | 54 bool res = q.try_pop(elem); in operator ()()
|
| H A D | test_async_node.cpp | 291 bool try_pop( T& item ) { in try_pop() function in async_activity_queue
362 if( is_active && my_work_queue.try_pop( work ) ) { in process()
685 while( my_q.try_pop(w) ) { in __anon62ab872d0a02()
|
| H A D | test_flow_graph_priorities.cpp | 220 bool try_pop(T& item) { in try_pop() function in ThreadsEagerReaction::concurrent_queue
269 while (activity->my_queue.try_pop(work)) { in operator ()()
|
| /oneTBB/src/tbb/ |
| H A D | task_stream.h | 199 popped = try_pop(lane); in pop()
245 d1::task* try_pop( unsigned lane_idx ) { in try_pop() function
|
| /oneTBB/doc/main/tbb_userguide/design_patterns/ |
| H A D | GUI_Thread.rst | 118 ResultQueue.try_pop(CurrentResult);
152 item from ResultQueue into CurrentResult. The ``try_pop`` always
|
| H A D | Non-Preemptive_Priorities.rst | 139 if( level[i].try_pop(item) )
|
| H A D | Local_Serializer.rst | 206 queue.try_pop(item);
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | concurrent_queue.h | 203 bool try_pop( T& result ) { in try_pop() function
502 bool try_pop( T& result ) { in try_pop() function
|
| H A D | concurrent_priority_queue.h | 199 bool try_pop( value_type& value ) { in try_pop() function
|
| /oneTBB/examples/concurrent_priority_queue/shortpath/ |
| H A D | shortpath.cpp | 124 while (open_set.try_pop(u_rec)) { in shortpath_helper()
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _flow_graph_impl.h | 183 bool result = my_priority_queue.try_pop(my_task); in next_task()
|