Home
last modified time | relevance | path

Searched refs:whenMap_ (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/foundation/resourceschedule/ffrt/src/queue/
H A Dserial_queue.cpp36 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()
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()
[all …]
H A Dconcurrent_queue.cpp43 whenMap_.insert({task->GetUptime(), task}); in Push()
56 whenMap_.insert({task->GetUptime(), task}); in Push()
62 whenMap_.insert({task->GetUptime(), task}); in Push()
63 if (task == whenMap_.begin()->second) { in Push()
76 if (!whenMap_.empty() && now >= whenMap_.begin()->first && !isExit_) { in Pull()
82 while (!whenMap_.empty() && now < whenMap_.begin()->first && !isExit_) { in Pull()
83 uint64_t diff = whenMap_.begin()->first - now; in Pull()
91 if (whenMap_.empty()) { in Pull()
100 return dequeFunc_(queueId_, now, whenMap_, nullptr); in Pull()
108 for (auto it = whenMap_.begin(); it != whenMap_.end(); it++) { in Stop()
[all …]
H A Deventhandler_adapter_queue.cpp131 tmpWhenMap.insert(whenMap_.begin(), whenMap_.end()); in Push()
132 whenMap_.swap(tmpWhenMap); in Push()
134 whenMap_.insert({task->GetUptime(), task}); in Push()
136 if (task == whenMap_.begin()->second) { in Push()
148 while (!whenMap_.empty() && now < whenMap_.begin()->first && !isExit_) { in Pull()
149 uint64_t diff = whenMap_.begin()->first - now; in Pull()
157 if (whenMap_.empty()) { in Pull()
165 return dequeFunc_(queueId_, now, whenMap_, &pulledTaskCount_); in Pull()
171 int nonIdleNum = std::count_if(whenMap_.cbegin(), whenMap_.cend(), in IsIdle()
184 DumpUnexecutedTaskInfo(tag, whenMap_, oss); in Dump()
[all …]
H A Dbase_queue.cpp54 Stop(whenMap_); in Stop()
67 Remove(whenMap_); in Remove()
81 return Remove(name, whenMap_); in Remove()
107 return Remove(task, whenMap_); in Remove()
128 return HasTask(name, whenMap_); in HasTask()
H A Dbase_queue.h61 return whenMap_.size(); in GetMapSize()
67 return whenMap_.empty() ? UINT64_MAX : whenMap_.begin()->first; in GetHeadUptime()
93 std::multimap<uint64_t, QueueTask*> whenMap_; variable