Searched refs:taskQueues (Results 1 – 1 of 1) sorted by relevance
110 Array<TaskQueue*> taskQueues; member116 taskQueues.reserve(threadCnt); in TaskSchedulerImpl()119 taskQueues.push(new TaskQueue); in TaskSchedulerImpl()129 for (auto tq = taskQueues.begin(); tq < taskQueues.end(); ++tq) { in ~TaskSchedulerImpl()136 for (auto tq = taskQueues.begin(); tq < taskQueues.end(); ++tq) { in ~TaskSchedulerImpl()149 if (taskQueues[(i + x) % threads.count]->tryPop(&task)) { in run()155 if (!success && !taskQueues[i]->pop(&task)) break; in run()167 if (taskQueues[(i + n) % threads.count]->tryPush(task)) return; in request()169 taskQueues[i % threads.count]->push(task); in request()
