Home
last modified time | relevance | path

Searched refs:consumers (Results 1 - 3 of 3) sorted by relevance

/foundation/resourceschedule/ffrt/src/core/
H A Dversion_ctx.cpp27 version->consumers.insert(consumer); in BuildConsumeRelationship()
77 // No consumers, directly into CONSUMED after being produced in onProduced()
78 if (consumers.empty()) { in onProduced()
82 } else { // if have consumers,notify them in onProduced()
94 auto it = std::as_const(consumers).find(consumer); in onConsumed()
95 if (it != consumers.end()) { in onConsumed()
96 consumers.erase(it); in onConsumed()
98 if (consumers.empty()) { in onConsumed()
127 consumers.insert(versionToMerge->consumers in MergeChildVersion()
[all...]
H A Dversion_ctx.h42 // Current version's consumers, notify all when ready
43 std::unordered_set<SCPUEUTask*> consumers; member
77 for (auto consumer : std::as_const(consumers)) { in NotifyConsumers()
92 for (const auto& consumer : std::as_const(v->consumers)) { in MergeConsumerInDep()
/foundation/resourceschedule/ffrt/src/sched/
H A Dscheduler.h125 for (auto task : data->consumers) { in UpdateVersion()

Completed in 2 milliseconds