Lines Matching refs:whenMap_

36     if (task->InsertHead() && !whenMap_.empty()) {  in Push()
38         uint64_t headTime = (whenMap_.begin()->first > 0) ? whenMap_.begin()->first - 1 : 0;  in Push()
39         whenMap_.insert({std::min(headTime, task->GetUptime()), task});  in Push()
41         whenMap_.insert({task->GetUptime(), task});  in Push()
44     if (task == whenMap_.begin()->second) {  in Push()
46     } else if ((whenMap_.begin()->second->GetDelay() > 0) && (GetNow() > whenMap_.begin()->first)) {  in Push()
51     if (whenMap_.size() >= overloadThreshold_) {  in Push()
52         FFRT_LOGW("[queueId=%u] overload warning, size=%llu", queueId_, whenMap_.size());  in Push()
64     while (!whenMap_.empty() && now < whenMap_.begin()->first && !isExit_) {  in Pull()
65         uint64_t diff = whenMap_.begin()->first - now;  in Pull()
73     if (whenMap_.empty()) {  in Pull()
81     return dequeFunc_(queueId_, now, whenMap_, nullptr);  in Pull()