| /oneTBB/test/conformance/ |
| H A D | conformance_mutex.h | 236 mutex_type* my_mutex; variable
249 my_mutex = &m; in acquire()
254 my_mutex = &m; in try_acquire()
263 my_mutex->my_iso_mutex.unlock(); in release()
264 my_mutex = nullptr; in release()
273 my_mutex = nullptr; in release()
283 my_mutex = &m; in acquire()
288 my_mutex = &m; in try_acquire()
299 my_mutex->my_iso_mutex.lock(); in upgrade_to_writer()
311 if (my_mutex) in ~scoped_lock()
[all …]
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _flow_graph_cache_impl.h | 34 typename mutex_type::scoped_lock lock( my_mutex ); in empty()
39 typename mutex_type::scoped_lock lock( my_mutex ); in add()
44 typename mutex_type::scoped_lock lock( my_mutex ); in remove()
60 mutex_type my_mutex; variable
224 mutex_type my_mutex; variable
243 typename mutex_type::scoped_lock l(my_mutex, true); in register_successor()
251 typename mutex_type::scoped_lock l(my_mutex, true); in remove_successor()
262 typename mutex_type::scoped_lock l(my_mutex, false); in empty()
279 mutex_type my_mutex; variable
296 typename mutex_type::scoped_lock l(my_mutex, true); in register_successor()
[all …]
|
| /oneTBB/doc/main/reference/ |
| H A D | custom_mutex_chmap.rst | 91 my_mutex_ptr->my_mutex.lock();
93 my_mutex_ptr->my_mutex.lock_shared();
108 my_mutex_ptr->my_mutex.lock();
110 my_mutex_ptr->my_mutex.lock_shared();
116 my_mutex_ptr->my_mutex.unlock();
118 my_mutex_ptr->my_mutex.unlock_shared();
126 my_mutex_ptr->my_mutex.unlock_shared();
127 my_mutex_ptr->my_mutex.lock();
134 my_mutex_ptr->my_mutex.unlock();
135 my_mutex_ptr->my_mutex.lock_shared();
[all …]
|
| /oneTBB/src/tbb/ |
| H A D | queuing_rw_mutex.cpp | 164 s.my_mutex = &m; in acquire()
180 ITT_NOTIFY(sync_prepare, s.my_mutex); in acquire()
220 ITT_NOTIFY(sync_prepare, s.my_mutex); in acquire()
250 ITT_NOTIFY(sync_acquired, s.my_mutex); in acquire()
275 s.my_mutex = &m; in try_acquire()
276 ITT_NOTIFY(sync_acquired, s.my_mutex); in try_acquire()
284 ITT_NOTIFY(sync_releasing, s.my_mutex); in release()
417 ITT_NOTIFY(sync_releasing, s.my_mutex); in downgrade_to_reader()
467 ITT_NOTIFY(sync_releasing, s.my_mutex); in upgrade_to_writer()
521 ITT_NOTIFY(sync_prepare, s.my_mutex); in upgrade_to_writer()
[all …]
|
| H A D | thread_request_serializer.cpp | 39 mutex_type::scoped_lock lock(my_mutex); in update()
47 mutex_type::scoped_lock lock(my_mutex); in set_active_num_workers()
84 mutex_type::scoped_lock lock(my_mutex, /* is_write = */ false); in register_mandatory_request()
99 mutex_type::scoped_lock lock(my_mutex, /* is_write = */ true); in set_active_num_workers()
|
| H A D | market.cpp | 53 mutex_type::scoped_lock lock(my_mutex); in register_client()
59 mutex_type::scoped_lock lock(my_mutex); in unregister_and_destroy_client()
114 mutex_type::scoped_lock lock(my_mutex); in set_active_num_workers()
126 mutex_type::scoped_lock lock(my_mutex); in adjust_demand()
|
| H A D | concurrent_monitor.h | 216 concurrent_monitor_mutex::scoped_lock l(my_mutex); in prepare_wait()
247 concurrent_monitor_mutex::scoped_lock l(my_mutex); in cancel_wait()
288 concurrent_monitor_mutex::scoped_lock l(my_mutex); in notify_one_relaxed()
327 concurrent_monitor_mutex::scoped_lock l(my_mutex); in notify_all_relaxed()
366 concurrent_monitor_mutex::scoped_lock l(my_mutex); in notify_relaxed()
401 concurrent_monitor_mutex::scoped_lock l(my_mutex); in notify_one_relaxed()
435 concurrent_monitor_mutex::scoped_lock l(my_mutex); in abort_all_relaxed()
457 my_mutex.destroy(); in destroy()
474 concurrent_monitor_mutex my_mutex{};
|
| H A D | co_context.h | 81 std::mutex my_mutex; member
177 std::unique_lock<std::mutex> lock(c.my_mutex); in coroutine_thread_func()
225 std::unique_lock<std::mutex> lock(c.my_mutex); in create_coroutine()
248 std::unique_lock<std::mutex> lock(new_coroutine.my_mutex); in swap_coroutine()
257 std::unique_lock<std::mutex> lock(prev_coroutine.my_mutex); in swap_coroutine()
265 std::unique_lock<std::mutex> lock(c.my_mutex); in destroy_coroutine()
|
| H A D | thread_request_serializer.h | 56 mutex_type my_mutex; variable
75 mutex_type my_mutex; variable
|
| H A D | task_stream.h | 50 mutex_t my_mutex{}; in alignas()
213 if( lock.try_acquire(lane.my_mutex) && !lane.my_queue.empty() ) { in pop_specific()
236 if( lock.try_acquire( lanes[lane_idx].my_mutex ) ) { in try_push()
251 if( lock.try_acquire( lane.my_mutex ) && !lane.my_queue.empty() ) { in try_pop()
|
| H A D | observer_proxy.h | 44 my_mutex_type my_mutex; variable
80 spin_rw_mutex& mutex () { return my_mutex.begin()[0]; } in mutex()
|
| H A D | market.h | 55 mutex_type my_mutex; variable
|
| /oneTBB/examples/graph/dining_philosophers/ |
| H A D | dining_philosophers.cpp | 103 oneapi::tbb::spin_mutex my_mutex; variable
208 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in forward()
216 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in eat()
221 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in eat()
228 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in think()
233 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in think()
285 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in main()
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | queuing_rw_mutex.h | 65 my_mutex = nullptr; in initialize()
88 if( my_mutex ) release(); in ~scoped_lock()
115 queuing_rw_mutex* my_mutex;
|
| H A D | flow_graph.h | 316 spin_mutex::scoped_lock l(my_mutex); in register_predecessor()
326 spin_mutex::scoped_lock l(my_mutex); in remove_predecessor()
353 spin_mutex my_mutex; variable
588 spin_mutex::scoped_lock lock(my_mutex); in __TBB_requires()
597 spin_mutex::scoped_lock lock(my_mutex); in __TBB_requires()
604 spin_mutex::scoped_lock lock(my_mutex); in __TBB_requires()
622 spin_mutex::scoped_lock lock(my_mutex); in __TBB_requires()
639 spin_mutex::scoped_lock lock(my_mutex); in __TBB_requires()
690 spin_mutex my_mutex; in __TBB_requires()
1891 spin_mutex my_mutex; variable
[all …]
|
| /oneTBB/test/tbb/ |
| H A D | test_concurrent_hash_map.cpp | 541 my_mutex_ptr->my_mutex.lock(); in scoped_lock()
554 my_mutex_ptr->my_mutex.lock(); in acquire()
558 if (m.my_mutex.try_lock()) { in try_acquire()
567 my_mutex_ptr->my_mutex.unlock(); in release()
592 std::mutex my_mutex; member in MinimalisticMutex
|
| H A D | test_flow_graph_whitebox.cpp | 205 tbb::spin_mutex::scoped_lock l(cnode.my_mutex); in TestContinueNode()
|