Lines Matching refs:taskQueue_

51     taskQueue_.resize(THREAD_POOL_MAX_TASKS);  in Init()
52     for (size_t t = 0; t < taskQueue_.size(); ++t) {  in Init()
53         taskQueue_[t].available = true;  in Init()
55             taskQueue_[t].subTaskFlag.emplace_back(new std::atomic_bool { false });  in Init()
68             if (*taskQueue_[k].subTaskFlag[threadIndex]) {  in ThreadRun()
69                 taskQueue_[k].task.processor(threadIndex);  in ThreadRun()
70                 *taskQueue_[k].subTaskFlag[threadIndex] = false;  in ThreadRun()
87     for (auto& task : taskQueue_) {  in ~ThreadPool()
132     taskQueue_[index].available = true;  in AddNewTask()
139         if (taskQueue_[i].available) {  in AcquireWorkIndex()
140             taskQueue_[i].available = false;  in AcquireWorkIndex()
149     taskQueue_[index].task = std::move(task);  in RunTask()
153         *taskQueue_[index].subTaskFlag[i] = true;  in RunTask()
157     taskQueue_[index].task.processor(0);  in RunTask()
164             if (*taskQueue_[index].subTaskFlag[i]) {  in RunTask()