Searched refs:concurrent_monitor (Results 1 – 6 of 6) sorted by relevance
30 std::size_t monitors_mem_size = sizeof(concurrent_monitor) * monitors_number; in allocate_bounded_queue_rep()33 concurrent_monitor* monitors = reinterpret_cast<concurrent_monitor*>(mem + queue_rep_size); in allocate_bounded_queue_rep()35 new (monitors + i) concurrent_monitor(); in allocate_bounded_queue_rep()43 concurrent_monitor* monitors = reinterpret_cast<concurrent_monitor*>(mem + queue_rep_size); in deallocate_bounded_queue_rep()45 monitors[i].~concurrent_monitor(); in deallocate_bounded_queue_rep()55 concurrent_monitor& monitor = monitors[monitor_tag]; in wait_bounded_queue_monitor()60 void __TBB_EXPORTED_FUNC abort_bounded_queue_monitors( concurrent_monitor* monitors ) { in abort_bounded_queue_monitors()61 concurrent_monitor& items_avail = monitors[d2::cbq_items_avail_tag]; in abort_bounded_queue_monitors()62 concurrent_monitor& slots_avail = monitors[d2::cbq_slots_avail_tag]; in abort_bounded_queue_monitors()74 void __TBB_EXPORTED_FUNC notify_bounded_queue_monitor( concurrent_monitor* monitors, in notify_bounded_queue_monitor()[all …]
481 class concurrent_monitor : public concurrent_monitor_base<std::uintptr_t> {486 ~concurrent_monitor() { in ~concurrent_monitor()
696 concurrent_monitor& m_monitor;730 delegated_task(d1::delegate_base& d, concurrent_monitor& s, d1::wait_context& wo) in delegated_task()750 concurrent_monitor::thread_context waiter((std::uintptr_t)&d); in execute()
246 concurrent_monitor my_exit_monitors;
56 tbb::detail::r1::concurrent_monitor test_monitor;66 tbb::detail::r1::concurrent_monitor::thread_context context{std::uintptr_t(1)}; in __anon1eb8c3140102()
295 class concurrent_monitor; variable304 class concurrent_monitor; variable308 … TBB_EXPORT void __TBB_EXPORTED_FUNC abort_bounded_queue_monitors( concurrent_monitor* monitors );309 …TBB_EXPORT void __TBB_EXPORTED_FUNC notify_bounded_queue_monitor( concurrent_monitor* monitors, st…311 …TBB_EXPORT void __TBB_EXPORTED_FUNC wait_bounded_queue_monitor( concurrent_monitor* monitors, std:…329 …void internal_wait(r1::concurrent_monitor* monitors, std::size_t monitor_tag, std::ptrdiff_t targe… in internal_wait()354 my_monitors = reinterpret_cast<r1::concurrent_monitor*>(my_queue_representation + 1); in concurrent_bounded_queue()662 r1::concurrent_monitor* my_monitors;