Lines Matching refs:async
69 static void asyncLoop(AsyncActivity* async) { in asyncLoop() argument
73 std::unique_lock<std::mutex> lock(async->m_mutex); in asyncLoop()
74 async->m_condvar.wait(lock, [async] {return !async->m_tagQueue.empty(); }); in asyncLoop()
75 tag = async->m_tagQueue.front(); in asyncLoop()
76 async->m_tagQueue.pop(); in asyncLoop()
217 static void asyncLoop(EpochAsyncActivity* async) { in asyncLoop() argument
221 std::unique_lock<std::mutex> lock(async->m_mutex); in asyncLoop()
222 async->m_condvar.wait(lock, [async] {return !async->m_tagQueue.empty(); }); in asyncLoop()
223 tag = async->m_tagQueue.front(); in asyncLoop()
224 async->m_tagQueue.pop(); in asyncLoop()
230 async->m_globalEpoch++; in asyncLoop()
267 EpochAsyncActivity async(4, global_epoch); in TestSuspendResume() local
278 tbb::task::suspend(EpochSuspendBody(async, global_epoch, local_epoch)); in TestSuspendResume()
284 tbb::task::suspend(EpochSuspendBody(async, global_epoch, local_epoch2)); in TestSuspendResume()
290 tbb::task::suspend(EpochSuspendBody(async, global_epoch, local_epoch)); in TestSuspendResume()