Home
last modified time | relevance | path

Searched refs:threadIndex (Results 1 - 2 of 2) sorted by relevance

/base/update/updater/services/script/threadpool/
H A Dthreadpool.cpp67 for (int32_t threadIndex = 0; threadIndex < threadNumber_; ++threadIndex) { in Init()
68 workers_.emplace_back(std::thread([this, threadIndex] { in Init()
69 ThreadExecute(this, threadIndex); in Init()
74 void ThreadPool::ThreadRun(int32_t threadIndex) in ThreadRun() argument
79 if (*taskQueue_[k].subTaskFlag[threadIndex]) { in ThreadRun()
80 taskQueue_[k].task.processor(threadIndex); in ThreadRun()
81 *taskQueue_[k].subTaskFlag[threadIndex] = false; in ThreadRun()
H A Dthread_pool.h54 void ThreadRun(int32_t threadIndex);
58 static void ThreadExecute(void* context, int32_t threadIndex) in ThreadExecute() argument
60 ((ThreadPool*)context)->ThreadRun(threadIndex); in ThreadExecute()

Completed in 2 milliseconds