| /foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | task_queue.cpp | 31 // -- TaskQueue ExecuteAsyncTask, runs TaskQueue::Execute.
32 TaskQueue::ExecuteAsyncTask::ExecuteAsyncTask(TaskQueue& queue) : queue_(queue) {} in ExecuteAsyncTask()
34 void TaskQueue::ExecuteAsyncTask::operator()() in operator ()()
40 void TaskQueue::ExecuteAsyncTask::Destroy() in Destroy()
45 // -- TaskQueue
46 TaskQueue::TaskQueue(const IThreadPool::Ptr& threadPool) : threadPool_(threadPool), isRunningAsync_(false) {} in TaskQueue() function in TaskQueue
48 TaskQueue
[all...] |
| H A D | task_queue.h | 61 class TaskQueue { class
66 explicit TaskQueue(const IThreadPool::Ptr& threadPool);
67 TaskQueue(const TaskQueue& other) = delete;
68 TaskQueue& operator=(const TaskQueue& other) = delete;
70 virtual ~TaskQueue();
103 explicit ExecuteAsyncTask(TaskQueue& queue);
110 TaskQueue& queue_;
|
| H A D | sequential_task_queue.h | 33 class SequentialTaskQueue final : public TaskQueue {
67 BASE_NS::vector<TaskQueue::Entry> tasks_;
|
| H A D | parallel_task_queue.h | 28 class ParallelTaskQueue final : public TaskQueue {
59 BASE_NS::vector<TaskQueue::Entry> tasks_;
|
| H A D | dispatcher_task_queue.h | 31 class DispatcherTaskQueue final : public TaskQueue {
|
| H A D | parallel_task_queue.cpp | 82 ParallelTaskQueue::ParallelTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool) {} in ParallelTaskQueue()
117 [afterIdentifier](const TaskQueue::Entry& entry) { return entry.identifier == afterIdentifier; }); in SubmitAfter()
|
| H A D | sequential_task_queue.cpp | 31 SequentialTaskQueue::SequentialTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool) {} in SequentialTaskQueue()
|
| H A D | dispatcher_task_queue.cpp | 34 DispatcherTaskQueue::DispatcherTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool) {} in DispatcherTaskQueue()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | task_queue.cpp | 19 TaskQueue::TaskQueue(bool lockable) in TaskQueue() function in DistributedDB::TaskQueue
23 TaskQueue::~TaskQueue() in ~TaskQueue()
26 void TaskQueue::PutTask(const Task &task) in PutTask()
34 Task TaskQueue::GetTaskAutoLock() in GetTaskAutoLock()
56 void TaskQueue::ReleaseLock() in ReleaseLock()
66 bool TaskQueue::IsEmptyAndUnlocked() const in IsEmptyAndUnlocked()
76 bool TaskQueue::CanGetTask() const in CanGetTask()
|
| H A D | task_pool_impl.h | 56 Task ReapTask(TaskQueue *&queue);
57 void GetTask(Task &task, TaskQueue *&queue);
62 void FinishExecuteTask(TaskQueue *taskQueue);
70 std::map<std::string, TaskQueue> queuedTasks_;
71 TaskQueue genericTasks_;
|
| H A D | task_queue.h | 24 class TaskQueue { class
26 explicit TaskQueue(bool lockable = true);
27 ~TaskQueue();
|
| H A D | task_pool_impl.cpp | 158 TaskQueue *tq = &pair.second; in SetThreadFree()
163 Task TaskPoolImpl::ReapTask(TaskQueue *&queue) in ReapTask()
177 TaskQueue *tq = &pair.second; in ReapTask()
187 void TaskPoolImpl::GetTask(Task &task, TaskQueue *&queue) in GetTask()
259 TaskQueue *taskQueue = nullptr; in TaskWorker()
275 void TaskPoolImpl::FinishExecuteTask(TaskQueue *taskQueue) in FinishExecuteTask()
|
| /foundation/multimedia/player_framework/services/utils/ |
| H A D | task_queue.cpp | 26 constexpr OHOS::HiviewDFX::HiLogLabel LABEL = { LOG_ONLY_PRERELEASE, LOG_DOMAIN_PLAYER, "TaskQueue" };
31 TaskQueue::~TaskQueue() in ~TaskQueue()
36 int32_t TaskQueue::Start() in Start()
42 thread_ = std::make_unique<std::thread>(&TaskQueue::TaskProcessor, this); in Start()
49 int32_t TaskQueue::Stop() noexcept
77 void TaskQueue::SetQos(const QosLevel level) in SetQos()
87 void TaskQueue::ResetQos() in ResetQos()
98 __attribute__((no_sanitize("cfi"))) int32_t TaskQueue::EnqueueTask(const std::shared_ptr<ITaskHandler> &task, in EnqueueTask()
137 __attribute__((no_sanitize("cfi"))) void TaskQueue
[all...] |
| /foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/engine_adapter/skia_adapter/ |
| H A D | skia_task_executor.h | 50 class TaskQueue { class
52 TaskQueue() = default;
53 ~TaskQueue() = default;
97 TaskQueue(const TaskQueue&) = delete;
98 void operator=(const TaskQueue&) = delete;
138 TaskQueue<Task, QUEUE_SIZE> taskQueue_;
|
| /foundation/multimedia/player_framework/services/utils/include/ |
| H A D | task_queue.h | 39 * TaskQueue taskQ("your_task_queue_name");
53 * TaskQueue taskQ("your_task_queue_name");
67 class TaskQueue;
112 friend class TaskQueue;
230 class __attribute__((visibility("default"))) TaskQueue : public NoCopyable { class
232 explicit TaskQueue(const std::string &name) : name_(name) {} in TaskQueue() function in OHOS::Media::TaskQueue
233 ~TaskQueue();
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_meta_manager.h | 65 using TaskQueue = std::shared_ptr<SafeBlockQueue<Backup>>;
100 TaskQueue queue, std::shared_ptr<ExecutorPool> executors, const NbDelegate store);
|
| /foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | executor_pool.h | 36 using TaskQueue = PriorityQueue<InnerTask, Time, TaskId>;
48 execs_ = new (std::nothrow) TaskQueue(InnerTask()); in ExecutorPool()
214 TaskQueue delayTasks_;
216 TaskQueue *execs_ = nullptr;
|
| /foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| H A D | executor_pool.h | 39 using TaskQueue = PriorityQueue<InnerTask, Time, TaskId>;
51 execs_ = new (std::nothrow) TaskQueue(InnerTask()); in ExecutorPool()
218 TaskQueue delayTasks_;
220 TaskQueue *execs_ = nullptr;
|
| /foundation/multimedia/player_framework/services/services/player/player_mem_manage/ |
| H A D | player_mem_manage.h | 79 std::unique_ptr<TaskQueue> probeTaskQueue_;
|
| /foundation/multimedia/player_framework/interfaces/kits/js/ |
| H A D | audio_recorder_napi.h | 85 std::unique_ptr<TaskQueue> taskQue_;
|
| /foundation/multimedia/player_framework/services/services/player/server/ |
| H A D | player_server_task_mgr.h | 77 std::unique_ptr<TaskQueue> taskThread_;
|
| H A D | player_server_task_mgr.cpp | 47 taskThread_ = std::make_unique<TaskQueue>("PlayerEngine"); in Init()
261 std::unique_ptr<TaskQueue> tmp; in Reset()
|
| /foundation/multimedia/player_framework/frameworks/js/metadatahelper/ |
| H A D | avimagegenerator_napi.h | 90 std::unique_ptr<TaskQueue> taskQue_;
|
| /foundation/multimedia/player_framework/services/services/avmetadatahelper/server/ |
| H A D | avmetadatahelper_server.h | 62 TaskQueue taskQue_;
|
| /foundation/multimedia/player_framework/services/services/transcoder/server/ |
| H A D | transcoder_server.h | 81 TaskQueue taskQue_;
|