Lines Matching refs:workerThread

74   if (cfg.workerThread.count > 0 && !cfg.workerThread.affinityPolicy) {  in setConfigDefaults()
75     cfg.workerThread.affinityPolicy = marl::Thread::Affinity::Policy::anyOf(  in setConfigDefaults()
139   for (int i = 0; i < cfg.workerThread.count; i++) {
143   for (int i = 0; i < cfg.workerThread.count; i++) {
160   for (int i = cfg.workerThread.count - 1; i >= 0; i--) {  in ~Scheduler()
163   for (int i = cfg.workerThread.count - 1; i >= 0; i--) {  in ~Scheduler()
173   if (cfg.workerThread.count > 0) {  in enqueue()
181         idx = nextEnqueueIndex++ % cfg.workerThread.count;  in enqueue()
206   if (cfg.workerThread.count > 0) {  in stealWork()
207     auto thread = workerThreads[from % cfg.workerThread.count];  in stealWork()
371       auto& affinityPolicy = scheduler->cfg.workerThread.affinityPolicy;  in start()
376         if (auto const& initFunc = scheduler->cfg.workerThread.initializer) {  in start()