Searched refs:maxThreads (Results 1 – 5 of 5) sorted by relevance
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
H A D | task_pool.cpp | 22 TaskPool *TaskPool::Create(int maxThreads, int minThreads, int &errCode) in Create() argument 24 TaskPool *taskPool = new (std::nothrow) TaskPoolImpl(maxThreads, minThreads); in Create()
|
H A D | task_pool_impl.cpp | 22 TaskPoolImpl::TaskPoolImpl(int maxThreads, int minThreads) in TaskPoolImpl() argument 28 maxThreads_(maxThreads), in TaskPoolImpl()
|
H A D | task_pool_impl.h | 32 TaskPoolImpl(int maxThreads, int minThreads);
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
H A D | task_pool.h | 45 static TaskPool *Create(int maxThreads, int minThreads, int &errCode);
|
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
H A D | task_manager.cpp | 536 uint32_t maxThreads = std::max(ConcurrentHelper::GetMaxThreads(), DEFAULT_THREADS); in TryExpand() local 537 maxThreads = (timeoutWorkers == 0) ? maxThreads : maxThreads + 2; // 2: extra threads in TryExpand() 538 if (workerCount < maxThreads && idleCount < targetNum) { in TryExpand() 539 uint32_t step = std::min(maxThreads, targetNum) - idleCount; in TryExpand() 541 if (step + workerCount > maxThreads) { in TryExpand() 542 step = maxThreads - workerCount; in TryExpand() 546 maxThreads, step, GetThreadNum()); in TryExpand()
|