Searched refs:singleThreadedWorkers (Results 1 – 2 of 2) sorted by relevance
104 marl::lock lock(singleThreadedWorkers.mutex); in bind()109 singleThreadedWorkers.byTid.emplace(tid, std::move(worker)); in bind()118 marl::lock lock(bound->singleThreadedWorkers.mutex); in unbind()120 auto it = bound->singleThreadedWorkers.byTid.find(tid); in unbind()121 MARL_ASSERT(it != bound->singleThreadedWorkers.byTid.end(), in unbind()124 bound->singleThreadedWorkers.byTid.erase(it); in unbind()125 if (bound->singleThreadedWorkers.byTid.empty()) { in unbind()126 bound->singleThreadedWorkers.unbind.notify_one(); in unbind()135 singleThreadedWorkers(config.allocator) {151 marl::lock lock(singleThreadedWorkers.mutex); in ~Scheduler()[all …]
512 SingleThreadedWorkers singleThreadedWorkers; variable