| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | task_queue.cpp | 32 TaskQueue::ExecuteAsyncTask::ExecuteAsyncTask(TaskQueue& queue) : queue_(queue) {} in ExecuteAsyncTask()
34 void TaskQueue::ExecuteAsyncTask::operator()() in operator ()()
40 void TaskQueue::ExecuteAsyncTask::Destroy() in Destroy()
46 TaskQueue::TaskQueue(const IThreadPool::Ptr& threadPool) : threadPool_(threadPool), isRunningAsync_… in TaskQueue() function in TaskQueue
48 TaskQueue::~TaskQueue() = default;
50 void TaskQueue::ExecuteAsync() in ExecuteAsync()
62 bool TaskQueue::IsRunningAsync() const in IsRunningAsync()
67 void TaskQueue::Wait() in Wait()
76 TaskQueue::Entry::Entry(uint64_t identifier, IThreadPool::ITask::Ptr task) : task(move(task)), iden… in Entry()
78 bool TaskQueue::Entry::operator==(uint64_t rhsIdentifier) const in operator ==()
[all …]
|
| H A D | task_queue.h | 61 class TaskQueue {
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 | parallel_task_queue.h | 28 class ParallelTaskQueue final : public TaskQueue { in CORE_BEGIN_NAMESPACE()
59 BASE_NS::vector<TaskQueue::Entry> tasks_; in CORE_BEGIN_NAMESPACE()
|
| H A D | sequential_task_queue.h | 33 class SequentialTaskQueue final : public TaskQueue { in CORE_BEGIN_NAMESPACE()
67 BASE_NS::vector<TaskQueue::Entry> tasks_; in CORE_BEGIN_NAMESPACE()
|
| 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 | dispatcher_task_queue.h | 31 class DispatcherTaskQueue final : public TaskQueue { in CORE_BEGIN_NAMESPACE()
|
| H A D | sequential_task_queue.cpp | 31 SequentialTaskQueue::SequentialTaskQueue(const IThreadPool::Ptr& threadPool) : TaskQueue(threadPool… in CORE_BEGIN_NAMESPACE()
|
| /ohos5.0/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 {
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()
|
| /ohos5.0/foundation/multimedia/player_framework/services/utils/ |
| H A D | task_queue.cpp | 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 in Stop()
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<ITaskHandl… in EnqueueTask()
137 __attribute__((no_sanitize("cfi"))) void TaskQueue::CancelNotExecutedTaskLocked() in CancelNotExecutedTaskLocked()
149 __attribute__((no_sanitize("cfi"))) void TaskQueue::TaskProcessor() in TaskProcessor()
199 bool TaskQueue::IsTaskExecuting() in IsTaskExecuting()
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/engine_adapter/skia_adapter/ |
| H A D | skia_task_executor.h | 50 class TaskQueue {
52 TaskQueue() = default;
53 ~TaskQueue() = default;
97 TaskQueue(const TaskQueue&) = delete;
98 void operator=(const TaskQueue&) = delete;
138 TaskQueue<Task, QUEUE_SIZE> taskQueue_;
|
| /ohos5.0/drivers/peripheral/usb/ddk/host/src/ |
| H A D | ddk_uevent_queue.cpp | 54 class TaskQueue { class
56 TaskQueue() = default;
59 ~TaskQueue();
153 void TaskQueue::Init(void) in Init()
177 void TaskQueue::UnInit(void) in UnInit()
188 TaskQueue::~TaskQueue() in ~TaskQueue()
193 int32_t TaskQueue::AddTask(const DdkUeventTaskInfo &task) in AddTask()
206 static TaskQueue g_taskQueue;
|
| /ohos5.0/base/hiviewdfx/hisysevent/interfaces/js/kits/napi/include/ |
| H A D | js_callback_manager.h | 30 using TaskQueue = std::queue<std::tuple<CallbackContext*, CALLBACK_FUNC, RELEASE_FUNC>>; variable
40 void Clear(TaskQueue& tasks);
46 TaskQueue jsCallbacks;
|
| /ohos5.0/foundation/multimedia/player_framework/services/utils/include/ |
| H A D | task_queue.h | 67 class TaskQueue; variable
112 friend class TaskQueue;
230 class __attribute__((visibility("default"))) TaskQueue : public NoCopyable {
232 explicit TaskQueue(const std::string &name) : name_(name) {}
233 ~TaskQueue();
|
| /ohos5.0/base/inputmethod/imf/frameworks/js/napi/inputmethodclient/ |
| H A D | async_call.h | 112 struct TaskQueue { struct
121 …napi_value Post(napi_env env, Context::ExecAction exec, std::shared_ptr<TaskQueue> queue, const ch… argument
135 std::shared_ptr<TaskQueue> queue = nullptr;
|
| /ohos5.0/foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| H A D | executor_pool.h | 39 using TaskQueue = PriorityQueue<InnerTask, Time, TaskId>; variable
51 execs_ = new (std::nothrow) TaskQueue(InnerTask()); in ExecutorPool()
218 TaskQueue delayTasks_;
220 TaskQueue *execs_ = nullptr;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | executor_pool.h | 36 using TaskQueue = PriorityQueue<InnerTask, Time, TaskId>; variable
48 execs_ = new (std::nothrow) TaskQueue(InnerTask()); in ExecutorPool()
214 TaskQueue delayTasks_;
216 TaskQueue *execs_ = nullptr;
|
| /ohos5.0/base/hiviewdfx/hisysevent/interfaces/js/kits/napi/src/ |
| H A D | js_callback_manager.cpp | 151 void JsCallbackManager::Clear(TaskQueue& tasks) in Clear()
153 TaskQueue empty; in Clear()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_meta_manager.h | 65 using TaskQueue = std::shared_ptr<SafeBlockQueue<Backup>>; variable
100 TaskQueue queue, std::shared_ptr<ExecutorPool> executors, const NbDelegate store);
|
| /ohos5.0/foundation/multimedia/player_framework/services/services/player/server/ |
| H A D | player_server_task_mgr.cpp | 47 taskThread_ = std::make_unique<TaskQueue>("PlayerEngine"); in Init()
274 std::unique_ptr<TaskQueue> tmp; in Reset()
|
| H A D | player_server_task_mgr.h | 79 std::unique_ptr<TaskQueue> taskThread_;
|
| /ohos5.0/foundation/multimedia/player_framework/services/services/player/player_mem_manage/ |
| H A D | player_mem_manage.h | 79 std::unique_ptr<TaskQueue> probeTaskQueue_;
|
| /ohos5.0/foundation/multimedia/player_framework/services/services/avmetadatahelper/server/ |
| H A D | avmetadatahelper_server.h | 61 TaskQueue taskQue_;
|