Lines Matching refs:concurrent_monitor
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()
51 void __TBB_EXPORTED_FUNC wait_bounded_queue_monitor( concurrent_monitor* monitors, std::size_t moni… in wait_bounded_queue_monitor()
55 concurrent_monitor& monitor = monitors[monitor_tag]; in wait_bounded_queue_monitor()
57 …monitor.wait<concurrent_monitor::thread_context>([&] { return !predicate(); }, std::uintptr_t(targ… 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()
78 concurrent_monitor& monitor = monitors[monitor_tag]; in notify_bounded_queue_monitor()