Lines Matching defs:qos
41 void NotifyTaskAdded(const QoS& qos) override;
42 void NotifyLocalTaskAdded(const QoS& qos) override;
43 void NotifyWorkers(const QoS& qos, int number) override;
45 std::mutex* GetSleepCtl(int qos) override
47 return &sleepCtl[qos].mutex;
50 void AddStealingWorker(const QoS& qos)
52 stealWorkers[qos].fetch_add(1);
55 void SubStealingWorker(const QoS& qos)
58 uint64_t stealWorkersNum = stealWorkers[qos].load();
62 if (atomic_compare_exchange_weak(&stealWorkers[qos], &stealWorkersNum, stealWorkersNum - 1)) return;
66 uint64_t GetStealingWorkers(const QoS& qos)
68 return stealWorkers[qos].load(std::memory_order_relaxed);
77 virtual void WakeupWorkers(const QoS& qos) = 0;
78 bool IncWorker(const QoS& qos) override;
79 int GetTaskCount(const QoS& qos);
80 int GetWorkerCount(const QoS& qos);
81 void WorkerJoinTg(const QoS& qos, pid_t pid);
86 void WorkerLeaveTg(const QoS& qos, pid_t pid);