Lines Matching refs:task
66 taskQueue_[k].task.processor(threadIndex); in ThreadRun()
84 for (auto& task : taskQueue_) { in ~ThreadPool() local
85 for (auto c : task.subTaskFlag) { in ~ThreadPool()
91 void ThreadPool::AddTask(Task &&task) in AddTask() argument
94 g_threadPool->AddNewTask(std::move(task)); in AddTask()
98 void ThreadPool::AddNewTask(Task &&task) in AddNewTask() argument
105 if (task.workSize <= 1 || index < 0) { in AddNewTask()
106 for (int32_t i = 0; i < task.workSize; ++i) { in AddNewTask()
107 task.processor(i); in AddNewTask()
112 int32_t workSize = task.workSize; in AddNewTask()
117 newTask.processor = [workSize, &task, this](int tId) { in AddNewTask()
119 task.processor(v); in AddNewTask()
124 RunTask(std::move(task), index); in AddNewTask()
144 void ThreadPool::RunTask(Task &&task, int32_t index) in RunTask() argument
146 int32_t workSize = task.workSize; in RunTask()
147 taskQueue_[index].task = std::move(task); in RunTask()
154 taskQueue_[index].task.processor(0); in RunTask()