Home
last modified time | relevance | path

Searched refs:workers_ (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/
H A Dthread_pool.cpp35 …: name_(name), numThreads_(numThreads), workers_(), isStopped_(false), mutex_(), taskCv_(), tasks_… in ThreadPool()
50 for (auto& threadInfo : workers_) { in ~ThreadPool()
61 workers_.reserve(numThreads_); in Initialize()
65 workers_.emplace_back(threadName, [this, threadName]() { WorkerLoop(threadName); }); in Initialize()
66 SetThreadName(workers_.back().thread.native_handle(), workers_.back().name); in Initialize()
91 for (auto& workerInfo : workers_) { in BeginBackgroundTasks()
99 for (auto& workerInfo : workers_) { in EndBackgroundTasks()
107 for (auto& workerInfo : workers_) { in SetThreadPoolPriority()
114 return GetThreadPriority(workers_[0].thread.native_handle()); in GetThreadPoolPriority()
121 for (auto& workerInfo : workers_) { in PrintThreadInfo()
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_manager.cpp98 for (auto& worker : workers_) { in ~TaskManager()
101 workers_.clear(); in ~TaskManager()
145 for (auto& worker : workers_) { in GetThreadInfos()
245 for (auto iter = workers_.begin(); iter != workers_.end(); iter++) { in CheckForBlockedWorkers()
467 if (workers_.find(*iter) == workers_.end()) { in NotifyShrink()
533 workerCount = workers_.size(); in TryExpand()
693 workers_.insert(worker); in NotifyWorkerAdded()
707 return std::count_if(workers_.begin(), workers_.end(), [](const auto& worker) { in GetRunningWorkers()
750 return workers_.size(); in GetThreadNum()
812 for (auto& worker : workers_) { in IsChooseIdle()
[all …]
H A Dtask_manager.h207 std::unordered_set<Worker*> workers_ {};
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp200 taskManager.workers_.clear(); in CheckForBlockedWorkers()
201 taskManager.workers_.insert(worker); in CheckForBlockedWorkers()
268 taskManager.workers_.clear(); in NotifyShrink()
279 taskManager.workers_.insert(worker1); in NotifyShrink()
280 taskManager.workers_.insert(worker2); in NotifyShrink()
285 taskManager.workers_.clear(); in NotifyShrink()
301 taskManager.workers_.clear(); in NotifyShrink()
308 taskManager.workers_.clear(); in TryExpand()
389 taskManager.workers_.clear(); in EnqueueTaskId()
392 taskManager.workers_.insert(worker); in EnqueueTaskId()
[all …]
/ohos5.0/base/update/updater/services/script/threadpool/
H A Dthreadpool.cpp68 workers_.emplace_back(std::thread([this, threadIndex] { in Init()
94 for (auto& worker : workers_) { in ~ThreadPool()
H A Dthread_pool.h70 std::vector<std::thread> workers_; variable
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/task_manager/
H A Dthread_pool.h83 std::vector<ThreadInfo> workers_; variable