Searched refs:whenMap_ (Results 1 - 5 of 5) sorted by relevance
| /foundation/resourceschedule/ffrt/src/queue/ |
| H A D | concurrent_queue.cpp | 43 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()
77 return dequeFunc_(queueId_, now, whenMap_, nullptr);
in Pull()
82 while (!whenMap_.empty() && now < whenMap_.begin()->first && !isExit_) {
in Pull()
83 uint64_t diff = whenMap_ in Pull()
[all...] |
| H A D | base_queue.cpp | 63 for (auto iter = whenMap_.begin(); iter != whenMap_.end();) {
in Remove()
68 iter = whenMap_.erase(iter);
in Remove()
83 auto range = whenMap_.equal_range(task->GetUptime());
in Remove()
86 whenMap_.erase(it);
in Remove()
97 auto iter = std::find_if(whenMap_.cbegin(), whenMap_.cend(),
in HasTask()
99 return iter != whenMap_.cend();
in HasTask()
116 for (auto it = whenMap_.begin(); it != whenMap_ in ClearWhenMap()
[all...] |
| H A D | serial_queue.cpp | 36 whenMap_.insert({task->GetUptime(), task}); in Push()
37 if (task == whenMap_.begin()->second) { in Push()
49 while (!whenMap_.empty() && now < whenMap_.begin()->first && !isExit_) { in Pull()
50 uint64_t diff = whenMap_.begin()->first - now; in Pull()
58 if (whenMap_.empty()) { in Pull()
66 return dequeFunc_(queueId_, now, whenMap_, nullptr); in Pull()
|
| H A D | eventhandler_adapter_queue.cpp | 131 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_, in Pull()
[all...] |
| H A D | base_queue.h | 62 return whenMap_.size();
in GetMapSize()
96 std::multimap<uint64_t, QueueTask*> whenMap_;
member in ffrt::BaseQueue
|
Completed in 2 milliseconds