Home
last modified time | relevance | path

Searched refs:job (Results 1 - 13 of 13) sorted by relevance

/foundation/multimedia/media_foundation/src/osal/task/
H A Dtask.cpp70 void Task::RegisterJob(const std::function<int64_t()>& job) in RegisterJob() argument
72 taskInner_->RegisterJob(job); in RegisterJob()
75 void Task::SubmitJobOnce(const std::function<void()>& job, int64_t delayUs, bool wait) in SubmitJobOnce() argument
77 taskInner_->SubmitJobOnce(job, delayUs, wait); in SubmitJobOnce()
80 void Task::SubmitJob(const std::function<void()>& job, int64_t delayUs, bool wait) in SubmitJob() argument
82 taskInner_->SubmitJob(job, delayUs, wait); in SubmitJob()
/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A Djobutils.cpp38 void SubmitJobOnce(std::function<void()> job) in SubmitJobOnce() argument
40 job(); in SubmitJobOnce()
44 JobHandle SubmitJobOnceAsync(std::function<void()> job) in SubmitJobOnceAsync() argument
47 job(); in SubmitJobOnceAsync()
H A DtaskInner.cpp115 MEDIA_LOG_D("task " PUBLIC_LOG_S " Start, job invalid", name_.c_str()); in Start()
228 void TaskInner::RegisterJob(const std::function<int64_t()>& job) in RegisterJob() argument
231 job_ = std::move(job); in RegisterJob()
234 void TaskInner::SubmitJobOnce(const std::function<void()>& job, int64_t delayUs, bool wait) in SubmitJobOnce() argument
237 int64_t time = InsertJob(job, delayUs, false); in SubmitJobOnce()
244 void TaskInner::SubmitJob(const std::function<void()>& job, int64_t delayUs, bool wait) in SubmitJob() argument
247 int64_t time = InsertJob(job, delayUs, true); in SubmitJob()
326 int64_t TaskInner::InsertJob(const std::function<void()>& job, int64_t delayUs, bool inJobQueue) in InsertJob() argument
336 while (jobQueue_.find(processTime) != jobQueue_.end()) { // To prevent dropping job unexpectedly in InsertJob()
340 jobQueue_[processTime] = std::move(job); in InsertJob()
[all...]
/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Djobutils.cpp37 void SubmitJobOnce(std::function<void()> job) in SubmitJobOnce() argument
39 JobHandle handle = ffrt::submit_h(job); in SubmitJobOnce()
44 JobHandle SubmitJobOnceAsync(std::function<void()> job) in SubmitJobOnceAsync() argument
46 JobHandle handle = ffrt::submit_h(job); in SubmitJobOnceAsync()
H A Dtask.cpp51 Task::Task(std::string name, std::function<void()> job, TaskPriority priority) in Task() argument
55 job_ = std::move(job); in Task()
144 void Task::RegisterJob(std::function<void()> job) in RegisterJob() argument
147 job_ = std::move(job); in RegisterJob()
/foundation/multimedia/media_foundation/tests/unittest/osal/
H A Dtask_inner_unit_test.cpp134 std::function<int64_t()> job = []() { in HWTEST_F() local
147 task->RegisterJob(job); in HWTEST_F()
148 task->SubmitJob(job, -1, false); in HWTEST_F()
164 std::function<int64_t()> job = []() { in HWTEST_F() local
177 task->RegisterJob(job); in HWTEST_F()
178 task->SubmitJobOnce(job, -1, false); in HWTEST_F()
/foundation/multimedia/media_foundation/engine/scene/recorder/internal/
H A Dstate_machine.cpp124 auto job = jobs_.Pop(timeoutMs); in DoTask() local
126 auto job = jobs_.Pop(); in DoTask()
128 if (!job) { in DoTask()
131 auto action = job(); in DoTask()
134 pendingJobs_.push(job); in DoTask()
142 job = pendingJobs_.front(); in DoTask()
144 action = job(); in DoTask()
146 pendingJobs_.push(job); in DoTask()
/foundation/multimedia/media_foundation/interface/inner_api/osal/task/
H A DtaskInner.h60 virtual void RegisterJob(const std::function<int64_t()>& job);
62 virtual void SubmitJobOnce(const std::function<void()>& job, int64_t delay, bool wait);
64 virtual void SubmitJob(const std::function<void()>& job, int64_t delay, bool wait);
97 void DoJob(const std::function<void()>& job);
105 int64_t InsertJob(const std::function<void()>& job, int64_t delayUs, bool inJobQueue);
H A Dtask.h60 virtual void RegisterJob(const std::function<int64_t()>& job);
62 virtual void SubmitJobOnce(const std::function<void()>& job, int64_t delayUs = 0, bool wait = false);
64 virtual void SubmitJob(const std::function<void()>& job, int64_t delayUs = 0, bool wait = false);
H A Djobutils.h32 void SubmitJobOnce(std::function<void()> job);
33 JobHandle SubmitJobOnceAsync(std::function<void()> job);
/foundation/multimedia/media_foundation/engine/scene/player/internal/
H A Dstate_machine.cpp134 auto job = jobs_.Pop(timeoutMs); in DoTask() local
136 auto job = jobs_.Pop(); in DoTask()
138 if (!job) { in DoTask()
141 auto action = job(); in DoTask()
144 pendingJobs_.push(job); in DoTask()
155 job = pendingJobs_.front(); in DoTask()
157 action = job(); in DoTask()
159 pendingJobs_.push(job); in DoTask()
/foundation/multimedia/audio_framework/services/audio_service/common/src/
H A Daudio_thread_task.cpp126 void AudioThreadTask::RegisterJob(std::function<void()> &&job) in RegisterJob() argument
128 job_ = std::move(job); in RegisterJob()
/foundation/multimedia/audio_framework/services/audio_service/common/include/
H A Daudio_thread_task.h39 void RegisterJob(std::function<void()> &&job);

Completed in 5 milliseconds