Lines Matching refs:ConcurrentHelper
88 ConcurrentHelper::UvHandleClose(timer_);
89 ConcurrentHelper::UvHandleClose(expandHandle_);
196 duration = ConcurrentHelper::GetMilliseconds() - task->startTime_;
243 bool state = (GetThreadNum() == ConcurrentHelper::GetMaxThreads()) && (GetIdleWorkers() == 0);
250 (ConcurrentHelper::GetMilliseconds() - worker->startTime_ < threshold) ||
264 worker->startTime_ = ConcurrentHelper::GetMilliseconds();
414 auto idleTime = ConcurrentHelper::GetMilliseconds() - worker->idlePoint_;
439 auto idleTime = ConcurrentHelper::GetMilliseconds() - worker->idlePoint_;
457 uint32_t minThread = ConcurrentHelper::IsLowMemory() ? 0 : DEFAULT_MIN_THREADS;
483 if (ConcurrentHelper::IsModerateMemory() && workerCount == idleNum && workerCount == DEFAULT_MIN_THREADS) {
496 if (!ConcurrentHelper::IsLowMemory() && workers_.empty()) {
536 uint32_t maxThreads = std::max(ConcurrentHelper::GetMaxThreads(), DEFAULT_THREADS);
567 ConcurrentHelper::UvHandleInit(loop_, expandHandle_, TaskManager::NotifyExpand);
1310 ConcurrentHelper::UvHandleClose(task->onResultSignal_);
1376 ConcurrentHelper::UvHandleClose(task->onStartExecutionSignal_);
1385 ConcurrentHelper::UvHandleClose(task->onStartExecutionSignal_);