/foundation/multimedia/media_foundation/src/osal/task/ |
H A D | task.cpp | 70 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 D | jobutils.cpp | 38 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 D | taskInner.cpp | 115 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 D | jobutils.cpp | 37 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 D | task.cpp | 51 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 D | task_inner_unit_test.cpp | 134 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 D | state_machine.cpp | 124 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 D | taskInner.h | 60 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 D | task.h | 60 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 D | jobutils.h | 32 void SubmitJobOnce(std::function<void()> job); 33 JobHandle SubmitJobOnceAsync(std::function<void()> job);
|
/foundation/multimedia/media_foundation/engine/scene/player/internal/ |
H A D | state_machine.cpp | 134 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 D | audio_thread_task.cpp | 126 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 D | audio_thread_task.h | 39 void RegisterJob(std::function<void()> &&job);
|