Home
last modified time | relevance | path

Searched refs:my_queue (Results 1 – 5 of 5) sorted by relevance

/oneTBB/src/tbb/
H A Dtask_stream.h49 queue_base_t my_queue{}; in alignas()
213 if( lock.try_acquire(lane.my_mutex) && !lane.my_queue.empty() ) { in pop_specific()
214 result = look_specific( lane.my_queue, isolation ); in pop_specific()
215 if( lane.my_queue.empty() ) in pop_specific()
237 lanes[lane_idx].my_queue.push_back( source ); in try_push()
251 if( lock.try_acquire( lane.my_mutex ) && !lane.my_queue.empty() ) { in try_pop()
252 result = this->get_item( lane.my_queue ); in try_pop()
253 if( lane.my_queue.empty() ) in try_pop()
/oneTBB/include/oneapi/tbb/detail/
H A D_flow_graph_node_impl.h69 , my_queue(!has_policy<rejecting, Policy>::value ? new input_queue_type() : nullptr) in function_input_base()
85 delete my_queue; in ~function_input_base() local
86 my_queue = nullptr; in ~function_input_base()
116 if(my_queue) { in reset_function_input_base()
117 my_queue->reset(); in reset_function_input_base()
128 input_queue_type *my_queue; variable
173 if(my_queue) { in perform_queued_requests()
174 if(!my_queue->empty()) { in perform_queued_requests()
176 new_task = create_body_task(my_queue->front()); in perform_queued_requests()
178 my_queue->pop(); in perform_queued_requests()
[all …]
H A D_concurrent_queue_base.h372 my_ticket_type(k), my_queue(queue), my_page(p), allocator(alloc) in micro_queue_pop_finalizer()
381 spin_mutex::scoped_lock lock( my_queue.page_mutex ); in ~micro_queue_pop_finalizer()
383 my_queue.head_page.store(q, std::memory_order_relaxed); in ~micro_queue_pop_finalizer()
385 my_queue.tail_page.store(nullptr, std::memory_order_relaxed); in ~micro_queue_pop_finalizer()
388 my_queue.head_counter.store(my_ticket_type, std::memory_order_release); in ~micro_queue_pop_finalizer()
396 Container& my_queue; variable
/oneTBB/test/tbb/
H A Dtest_flow_graph_priorities.cpp260 concurrent_queue<work_type> my_queue; member
269 while (activity->my_queue.try_pop(work)) { in operator ()()
283 my_queue.push(work); in submit()
H A Dtest_flow_graph_whitebox.cpp271 CHECK_MESSAGE( (!fnode0.my_queue), "node should have no queue"); in TestFunctionNode()
297 CHECK_MESSAGE( (fnode1.my_queue), "node should have no queue"); in TestFunctionNode()