Home
last modified time | relevance | path

Searched defs:lock (Results 1 – 25 of 44) sorted by relevance

12

/oneTBB/src/tbb/
H A Dobserver_proxy.cpp55 scoped_lock lock(mutex(), /*is_writer=*/true); in clear() local
81 scoped_lock lock(mutex(), /*is_writer=*/false); in clear() local
91 scoped_lock lock(mutex(), /*is_writer=*/true); in insert() local
134 observer_list::scoped_lock lock(mutex(), /*is_writer=*/true); in remove_ref() local
153 scoped_lock lock(mutex(), /*is_writer=*/false); in do_notify_entry_observers() local
214 scoped_lock lock(mutex(), /*is_writer=*/false); in do_notify_exit_observers() local
303 observer_list::scoped_lock lock(list.mutex(), /*is_writer=*/true); in observe() local
H A Dthread_request_serializer.cpp39 mutex_type::scoped_lock lock(my_mutex); in update() local
47 mutex_type::scoped_lock lock(my_mutex); in set_active_num_workers() local
84 mutex_type::scoped_lock lock(my_mutex, /* is_write = */ false); in register_mandatory_request() local
99 mutex_type::scoped_lock lock(my_mutex, /* is_write = */ true); in set_active_num_workers() local
114 void thread_request_serializer_proxy::enable_mandatory_concurrency(mutex_type::scoped_lock& lock) { in enable_mandatory_concurrency()
125 void thread_request_serializer_proxy::disable_mandatory_concurrency(mutex_type::scoped_lock& lock) { in disable_mandatory_concurrency()
H A Dthreading_control.cpp215 global_mutex_type::scoped_lock lock(g_threading_control_mutex); in create_threading_control() local
248 void threading_control::wait_last_reference(global_mutex_type::scoped_lock& lock) { in wait_last_reference()
268 global_mutex_type::scoped_lock lock(g_threading_control_mutex); in release() local
290 global_mutex_type::scoped_lock lock(g_threading_control_mutex); in register_public_reference() local
309 global_mutex_type::scoped_lock lock(g_threading_control_mutex); in create_client() local
341 global_mutex_type::scoped_lock lock(g_threading_control_mutex); in is_present() local
346 global_mutex_type::scoped_lock lock(g_threading_control_mutex); in register_lifetime_control() local
353 global_mutex_type::scoped_lock lock(g_threading_control_mutex); in unregister_lifetime_control() local
384 global_mutex_type::scoped_lock lock(g_threading_control_mutex); in max_num_workers() local
H A Dmarket.cpp53 mutex_type::scoped_lock lock(my_mutex); in register_client() local
59 mutex_type::scoped_lock lock(my_mutex); in unregister_and_destroy_client() local
114 mutex_type::scoped_lock lock(my_mutex); in set_active_num_workers() local
126 mutex_type::scoped_lock lock(my_mutex); in adjust_demand() local
H A Dglobal_control.cpp61 spin_mutex::scoped_lock lock(my_list_mutex); // protect my_list.empty() call in active_value() local
84 spin_mutex::scoped_lock lock(my_list_mutex); // protect my_list.empty() call in active_value() local
193 spin_mutex::scoped_lock lock(c->my_list_mutex); in create() local
206 spin_mutex::scoped_lock lock(c->my_list_mutex); in destroy() local
229 spin_mutex::scoped_lock lock(c->my_list_mutex); in remove_and_check_if_empty() local
239 spin_mutex::scoped_lock lock(c->my_list_mutex); in is_present() local
H A Dconcurrent_monitor_mutex.h46 void lock() { in lock() function
H A Dmain.h61 static void lock() { in lock() function
H A Dtask_stream.h212 mutex::scoped_lock lock; in pop_specific() local
235 mutex::scoped_lock lock; in try_push() local
250 mutex::scoped_lock lock; in try_pop() local
H A Dthread_dispatcher.cpp58 client_list_mutex_type::scoped_lock lock(my_list_mutex); in register_client() local
160 client_list_mutex_type::scoped_lock lock(my_list_mutex, /*is_writer=*/false); in client_in_need() local
H A Dtcm_adaptor.cpp130 tcm_client_mutex_type::scoped_lock lock(my_permit_mutex); in actualize_permit() local
289 tcm_adaptor_impl::demand_mutex_type::scoped_lock lock(my_impl->my_demand_mutex); in unregister_and_destroy_client() local
303 tcm_adaptor_impl::demand_mutex_type::scoped_lock lock(my_impl->my_demand_mutex); in adjust_demand() local
/oneTBB/include/oneapi/tbb/detail/
H A D_mutex_common.h33 requires( Lock& lock, Mutex& mutex ) { in requires()
42 requires( Lock& lock, Mutex& mutex ) { in requires()
/oneTBB/examples/graph/dining_philosophers/
H A Ddining_philosophers.cpp208 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in forward() local
216 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in eat() local
221 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in eat() local
228 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in think() local
233 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in think() local
285 oneapi::tbb::spin_mutex::scoped_lock lock(my_mutex); in main() local
/oneTBB/test/tbb/
H A Dtest_mutex.h45 typename mutex_type::scoped_lock lock; in flog_once() local
120 typename mutex_type::scoped_lock lock; in flog_once() local
225 scoped_lock lock; in TestIsWriter() local
230 scoped_lock lock; in TestIsWriter() local
H A Dtest_resumable_tasks.cpp50 std::lock_guard<std::mutex> lock(m_mutex); in ~AsyncActivity() local
63 std::lock_guard<std::mutex> lock(m_mutex); in submit() local
73 std::unique_lock<std::mutex> lock(async->m_mutex); in asyncLoop() local
198 std::lock_guard<std::mutex> lock(m_mutex); in ~EpochAsyncActivity() local
211 std::lock_guard<std::mutex> lock(m_mutex); in submit() local
221 std::unique_lock<std::mutex> lock(async->m_mutex); in asyncLoop() local
H A Dtest_scheduler_mix.cpp224 void lock() { in lock() function in PtrRWMutex
437 ScopedLock lock; in destroy() local
459 ScopedLock lock{ arena, true }; in shutdown() local
469 std::pair<tbb::task_arena*, std::size_t> acquire(Random& rnd, ScopedLock& lock) { in acquire()
495 void release(ScopedLock& lock) { in release()
548 ArenaTable::ScopedLock lock; in do_it() local
H A Dtest_mutex.cpp85 typename C::mutex_type::scoped_lock lock(counter.mutex); in operator ()() local
/oneTBB/src/tbbmalloc/
H A Dbackref.cpp182 MallocMutex::scoped_lock lock(mainMutex); // ... and share under lock in requestNewSpace() local
219 MallocMutex::scoped_lock lock(mainMutex); in findFreeBlock() local
275 MallocMutex::scoped_lock lock(blockToUse->blockMutex); in newBackRef() local
331 MallocMutex::scoped_lock lock(currBlock->blockMutex); in removeBackRef() local
346 MallocMutex::scoped_lock lock(mainMutex); in removeBackRef() local
H A DSynchronize.h36 void lock() { in lock() function
H A Dbackend.cpp54 MallocMutex::scoped_lock lock(mutex); in registerAlloc() local
66 MallocMutex::scoped_lock lock(mutex); in registerFree() local
776 MallocMutex::scoped_lock lock( bootsrapMemStatusMutex ); in requestBootstrapMem() local
1300 MallocMutex::scoped_lock lock(regionListLock); in add() local
1309 MallocMutex::scoped_lock lock(regionListLock); in remove() local
1322 MallocMutex::scoped_lock lock(regionListLock); in reportStat() local
1465 MallocMutex::scoped_lock lock(tLock); in countFreeBlocks() local
1475 MallocMutex::scoped_lock lock(tLock); in reportFreeBlocks() local
/oneTBB/include/oneapi/tbb/
H A Dmutex.h54 void lock() { in lock() function
H A Dnull_rw_mutex.h71 void lock() {} in lock() function
H A Dnull_mutex.h67 void lock() {} in lock() function
H A Dspin_mutex.h68 void lock() { in lock() function
H A Drw_mutex.h55 void lock() { in lock() function
/oneTBB/python/rml/
H A Dipc_server.cpp888 asleep_list_mutex_type::scoped_lock lock; in try_insert_in_asleep_list() local
905 asleep_list_mutex_type::scoped_lock lock; in try_insert_in_asleep_list_forced() local
956 asleep_list_mutex_type::scoped_lock lock(my_asleep_list_mutex); in wake_some() local
1002 asleep_list_mutex_type::scoped_lock lock(my_asleep_list_mutex); in wake_one_forced() local
1040 asleep_list_mutex_type::scoped_lock lock(my_asleep_list_mutex); in stop_one() local

12