Home
last modified time | relevance | path

Searched refs:ticket (Results 1 – 3 of 3) sorted by relevance

/oneTBB/src/tbb/
H A Dconcurrent_bounded_queue.cpp70 predicate_leq( std::size_t ticket ) : my_ticket(ticket) {} in predicate_leq()
71 …bool operator() ( std::uintptr_t ticket ) const { return static_cast<std::size_t>(ticket) <= my_ti… in operator ()()
75 … std::size_t monitor_tag, std::size_t ticket) in notify_bounded_queue_monitor() argument
79 monitor.notify(predicate_leq(ticket)); in notify_bounded_queue_monitor()
/oneTBB/include/oneapi/tbb/
H A Dconcurrent_queue.h33 ticket_type ticket{}; in internal_try_pop_impl()
40 return { false, ticket }; in internal_try_pop_impl()
44 } while (!queue.head_counter.compare_exchange_strong(ticket, ticket + 1)); in internal_try_pop_impl()
45 } while (!queue.choose(ticket).pop(dst, ticket, queue, alloc)); in internal_try_pop_impl()
46 return { true, ticket }; in internal_try_pop_impl()
560 std::ptrdiff_t target = ticket - my_capacity; in internal_push()
574 …my_queue_representation->choose(ticket).abort_push(ticket, *my_queue_representation, my_allocator); in internal_push()
579 …my_queue_representation->choose(ticket).push(ticket, *my_queue_representation, my_allocator, std::… in internal_push()
593 … } while (!my_queue_representation->tail_counter.compare_exchange_strong(ticket, ticket + 1)); in internal_push_if_not_full()
595 …my_queue_representation->choose(ticket).push(ticket, *my_queue_representation, my_allocator, std::… in internal_push_if_not_full()
[all …]
/oneTBB/test/tbb/
H A Dtest_task.cpp390 int ticket = 0; in __anon509d20bd0b02() local
392 ticket = suspend_flag++; in __anon509d20bd0b02()
395 if (ticket % 5 == 0) { in __anon509d20bd0b02()
433 std::size_t ticket = my_current_task++; in execute() local
434 task* next = ticket < my_task_pool.size() ? &my_task_pool[ticket] : nullptr; in execute()
484 std::size_t ticket = bypass_task::my_current_task++; variable
485 if (ticket < test_task_pool.size()) {
486 tbb::detail::d1::spawn(test_task_pool[ticket], test_context);