Lines Matching refs:job
115 MEDIA_LOG_D("task " PUBLIC_LOG_S " Start, job invalid", name_.c_str());
228 void TaskInner::RegisterJob(const std::function<int64_t()>& job)
231 job_ = std::move(job);
234 void TaskInner::SubmitJobOnce(const std::function<void()>& job, int64_t delayUs, bool wait)
237 int64_t time = InsertJob(job, delayUs, false);
244 void TaskInner::SubmitJob(const std::function<void()>& job, int64_t delayUs, bool wait)
247 int64_t time = InsertJob(job, delayUs, true);
326 int64_t TaskInner::InsertJob(const std::function<void()>& job, int64_t delayUs, bool inJobQueue)
336 while (jobQueue_.find(processTime) != jobQueue_.end()) { // To prevent dropping job unexpectedly
340 jobQueue_[processTime] = std::move(job);
342 while (msgQueue_.find(processTime) != msgQueue_.end()) { // To prevent dropping job unexpectedly
346 msgQueue_[processTime] = std::move(job);