Home
last modified time | relevance | path

Searched refs:Task (Results 1 - 25 of 299) sorted by relevance

12345678910>>...12

/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/task/
H A Dtask.cpp23 Task::Task(const std::string &networkId, const std::string &uuid, const std::string &udid, const std::string &dhId, in Task() function in OHOS::DistributedHardware::Task
28 Task::~Task() in ~Task()
33 std::string Task::GetId() in GetId()
38 std::string Task::GetNetworkId() in GetNetworkId()
43 std::string Task::GetUUID() in GetUUID()
48 std::string Task::GetUDID() in GetUDID()
53 std::string Task::GetDhId() in GetDhId()
58 DHType Task
[all...]
/foundation/multimedia/media_foundation/src/osal/task/
H A Dtask.cpp15 #define HST_LOG_TAG "Task"
22 void Task::SleepInTask(unsigned ms) in SleepInTask()
27 void Task::SetEnableStateChangeLog(bool enable) in SetEnableStateChangeLog()
34 Task::Task(const std::string& name, const std::string& groupId, TaskType type, TaskPriority priority, bool singleLoop) in Task() function in OHOS::Media::Task
40 Task::~Task() in ~Task()
45 void Task::Start() in Start()
50 void Task::Stop() in Stop()
55 void Task
[all...]
/foundation/arkui/ace_engine/frameworks/base/thread/
H A Dtask_executor.h49 using Task = std::function<void()>;
68 * @param task Task which need execution.
74 Task&& task, TaskType type, const std::string& name, PriorityType priorityType = PriorityType::LOW) const in PostTask()
82 * @param task Task which need execution.
87 bool PostTask(const Task& task, TaskType type, const std::string& name, in PostTask()
96 * @param task Task which need execution.
102 bool PostTaskWithTraceId(Task&& task, TaskType type, int32_t id, const std::string& name) const in PostTaskWithTraceId()
104 Task wrappedTask = WrapTaskWithTraceId(std::move(task), id); in PostTaskWithTraceId()
111 * @param task Task which need execution.
117 bool PostTaskWithTraceId(const Task
[all...]
H A Dbackground_task_executor.h38 using Task = std::function<void()>;
42 bool PostTask(Task&& task, BgTaskPriority priority = BgTaskPriority::DEFAULT);
43 bool PostTask(const Task& task, BgTaskPriority priority = BgTaskPriority::DEFAULT);
56 std::list<Task> tasks_;
57 std::list<Task> lowPriorityTasks_;
/foundation/graphic/graphic_2d/rosen/modules/hyper_graphic_manager/core/frame_rate_manager/
H A Dhgm_task_handle_thread.h28 template<typename Task>
31 static auto Create(Task&& task) in Create()
33 sptr<ScheduledTask<Task>> t(new ScheduledTask(std::forward<Task&&>(task))); in Create()
43 explicit ScheduledTask(Task&& task) : task_(std::move(task)) {} in ScheduledTask()
46 using Return = std::invoke_result_t<Task>;
60 template<typename Task, typename Return = std::invoke_result_t<Task>>
61 std::future<Return> ScheduleTask(Task&& task) in ScheduleTask()
63 auto [scheduledTask, taskFuture] = HgmDetail::ScheduledTask<Task> in ScheduleTask()
[all...]
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/task/
H A Dtask.h29 class Task : public std::enable_shared_from_this<Task> { class
31 Task() = delete;
32 Task(const std::string &networkId, const std::string &uuid, const std::string &udid, const std::string &dhId,
34 virtual ~Task();
51 virtual void AddChildrenTask(std::shared_ptr<Task> childrenTask);
52 const std::vector<std::shared_ptr<Task>> GetChildrenTasks();
54 const std::weak_ptr<Task> GetFatherTask();
55 void SetFatherTask(std::shared_ptr<Task> fatherTask);
71 std::weak_ptr<Task> fatherTask
[all...]
/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Dtask.cpp16 #define HST_LOG_TAG "Task"
22 constexpr OHOS::HiviewDFX::HiLogLabel LABEL = { LOG_CORE, LOG_DOMAIN_FOUNDATION, "Task" };
45 Task::Task(std::string name, TaskPriority priority) in Task() function in OHOS::Media::Task
51 Task::Task(std::string name, std::function<void()> job, TaskPriority priority) in Task() function in OHOS::Media::Task
52 : Task(std::move(name), priority) in Task()
58 Task::~Task() in ~Task()
65 void Task
[all...]
/foundation/multimedia/media_foundation/engine/foundation/osal/thread/
H A Dtask.cpp15 #define HST_LOG_TAG "Task"
24 Task::Task(std::string name, ThreadPriority priority) in Task() function in OHOS::Media::OSAL::Task
32 Task::Task(std::string name, std::function<void()> handler, ThreadPriority priority) in Task() function in OHOS::Media::OSAL::Task
33 : Task(std::move(name), priority) in Task()
39 Task::~Task() in ~Task()
46 void Task::Start() in Start()
63 void Task
[all...]
/foundation/communication/netstack/frameworks/js/napi/socket/task_queue/src/
H A Dtask_queue.cpp24 namespace OHOS::NetStack::Socket::Task { namespace in OHOS::NetStack::Socket
25 class Task { class
27 Task() : executor(nullptr), callback(nullptr), data(nullptr), priority_(TaskPriority::CLOSE) {} in Task() function in OHOS::NetStack::Socket::Task::Task
29 Task(TaskPriority priority, AsyncWorkExecutor exec, AsyncWorkCallback call, void *d) in Task() function in OHOS::NetStack::Socket::Task::Task
34 ~Task() = default;
36 bool operator<(const Task &e) const in operator <()
49 std::priority_queue<Task> g_taskExecutorQueue; /* NOLINT */
51 std::priority_queue<Task> g_taskCallbackQueue; /* NOLINT */
59 Task task; in Executor()
94 Task tas in Callback()
[all...]
/foundation/multimedia/media_foundation/tests/unittest/osal/
H A Dtask_func_unit_test.cpp27 #define HST_LOG_TAG "Task"
87 std::shared_ptr<Task> task1 = std::make_shared<Task>("workTask1"); in HWTEST_F()
99 std::shared_ptr<Task> task2 = std::make_shared<Task>("workTask2"); in HWTEST_F()
105 MEDIA_LOG_I("Task TaskRegisterJobNotRunning running at " PUBLIC_LOG_U32, count); in HWTEST_F()
125 std::shared_ptr<Task> task3 = std::make_shared<Task>("workTask3"); in HWTEST_F()
131 MEDIA_LOG_I("Task TaskRegisterJobRun running at " PUBLIC_LOG_U32, count); in HWTEST_F()
152 std::shared_ptr<Task> task in HWTEST_F()
[all...]
H A Dtask_inner_unit_test.cpp18 #define HST_LOG_TAG "Task"
72 std::shared_ptr<Task> task = std::make_shared<Task>("workTask"); in HWTEST_F()
105 std::shared_ptr<Task> task = std::make_shared<Task>("workTask", groupId_, TaskType::SINGLETON, in HWTEST_F()
132 std::shared_ptr<Task> task = std::make_shared<Task>("workTask", groupId_, TaskType::SINGLETON, in HWTEST_F()
162 std::shared_ptr<Task> task = std::make_shared<Task>("workTask", groupId_, TaskType::SINGLETON, in HWTEST_F()
/foundation/arkui/ui_lite/frameworks/core/
H A Dtask_manager.cpp28 void TaskManager::Add(Task* task) in Add()
34 ListNode<Task*>* pos = list_.Begin(); in Add()
46 void TaskManager::Remove(Task* task) in Remove()
51 ListNode<Task*>* pos = list_.Begin(); in Remove()
72 ListNode<Task*>* node = list_.Begin(); in TaskHandler()
75 Task* currentTask = node->data_; in TaskHandler()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
H A Dithread_pool.h23 using Task = std::function<void()>;
31 virtual TaskId Execute(const Task &task) = 0;
33 virtual TaskId Execute(const Task &task, Duration delay) = 0;
35 virtual TaskId Schedule(const Task &task, Duration interval) = 0;
37 virtual TaskId Schedule(const Task &task, Duration delay, Duration interval) = 0;
39 virtual TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) = 0;
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dtask_executor_adapter.h24 using Task = std::function<void()>;
28 TaskId Execute(const Task &task) override;
29 TaskId Execute(const Task &task, Duration delay) override;
30 TaskId Schedule(const Task &task, Duration interval) override;
31 TaskId Schedule(const Task &task, Duration delay, Duration interval) override;
32 TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) override;
/foundation/multimodalinput/input/intention/scheduler/task_scheduler/include/
H A Dtask_scheduler.h40 class Task : public std::enable_shared_from_this<Task> { class in OHOS::Msdp::DeviceStatus::final
44 using TaskPtr = std::shared_ptr<TaskScheduler::Task>;
45 Task(int32_t id, DTaskCallback fun, Promise *promise = nullptr) in Task() function in OHOS::Msdp::DeviceStatus::final::Task
47 ~Task() = default;
69 using TaskPtr = Task::TaskPtr;
70 using Promise = Task::Promise;
71 using Future = Task::Future;
/foundation/multimodalinput/input/service/delegate_task/include/
H A Ddelegate_tasks.h38 class Task : public std::enable_shared_from_this<Task> { class in OHOS::MMI::final
42 using TaskPtr = std::shared_ptr<DelegateTasks::Task>;
43 Task(int32_t id, DTaskCallback fun, Promise *promise = nullptr) in Task() function in OHOS::MMI::final::Task
45 ~Task() = default;
67 using TaskPtr = Task::TaskPtr;
68 using Promise = Task::Promise;
69 using Future = Task::Future;
/foundation/arkui/ace_engine/frameworks/core/common/
H A Dtask_executor_impl.h45 void AddTaskObserver(Task&& callback) override {};
61 TaskExecutor::Task WrapTaskWithContainer(
62 TaskExecutor::Task&& task, int32_t id, std::function<void()>&& traceIdFunc = nullptr) const;
63 TaskExecutor::Task WrapTaskWithCustomWrapper(
64 TaskExecutor::Task&& task, int32_t id, std::function<void()>&& traceIdFunc = nullptr) const;
65 bool PostTaskToTaskRunner(const RefPtr<TaskRunnerAdapter>& taskRunner, TaskExecutor::Task&& task,
68 bool OnPostTask(Task&& task, TaskType type, uint32_t delayTime, const std::string& name,
70 Task WrapTaskWithTraceId(Task&& task, int32_t id) const final;
72 bool OnPostTaskWithoutTraceId(Task
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Dmock_thread_pool.h23 MOCK_METHOD1(Execute, TaskId(const Task &));
24 MOCK_METHOD2(Execute, TaskId(const Task &, Duration));
25 MOCK_METHOD2(Schedule, TaskId(const Task &, Duration));
26 MOCK_METHOD3(Schedule, TaskId(const Task &, Duration, Duration));
27 MOCK_METHOD4(Schedule, TaskId(const Task &, Duration, Duration, uint64_t));
H A Dthread_pool_test_stub.h30 TaskId Execute(const Task &task) override;
32 TaskId Execute(const Task &task, Duration delay) override;
34 TaskId Schedule(const Task &task, Duration interval) override;
36 TaskId Schedule(const Task &task, Duration delay, Duration interval) override;
38 TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) override;
/foundation/arkui/ace_engine/test/unittest/core/pattern/scroll/
H A Dmock_task_executor.h30 bool OnPostTask(Task&& task, TaskType type, uint32_t delayTime, const std::string& name,
53 Task WrapTaskWithTraceId(Task&& /*task*/, int32_t /*id*/) const override
58 void AddTaskObserver(Task&& callback) override {}
64 bool OnPostTaskWithoutTraceId(Task&& task, TaskType type, uint32_t delayTime, const std::string& name,
77 mutable Task delayTask_;
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
H A Dtask_manager.h24 using Task = std::function<void()>;
29 TaskId Execute(const Task &task) override;
30 TaskId Execute(const Task &task, Duration delay) override;
31 TaskId Schedule(const Task &task, Duration interval) override;
32 TaskId Schedule(const Task &task, Duration delay, Duration interval) override;
33 TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) override;
/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/
H A Dtask_queue_factory.cpp80 // Task state which can be waited and marked as done.
164 q_.Push(Task(move(function), taskState));
180 q_.Push(Task(move(function)));
229 struct Task { struct in __anon9628::final
233 ~Task() = default;
234 Task() = default;
235 explicit Task(ITask::Ptr&& function, std::shared_ptr<TaskResult::State> state) in Task() function
240 explicit Task(ITask::Ptr&& function) : function_(move(function)) in Task() function
244 Task(Task in Task()
[all...]
/foundation/arkui/ace_engine/test/mock/base/
H A Dmock_task_executor.h30 bool OnPostTask(Task&& task, TaskType type, uint32_t delayTime, const std::string& name,
46 Task WrapTaskWithTraceId(Task&& /*task*/, int32_t /*id*/) const override
51 void AddTaskObserver(Task&& callback) override {}
57 bool OnPostTaskWithoutTraceId(Task&& task, TaskType type, uint32_t delayTime, const std::string& name,
/foundation/window/window_manager/window_scene/common/include/
H A Dtask_scheduler.h34 using Task = std::function<void()>;
35 void PostAsyncTask(Task&& task, const std::string& name = "ssmTask", int64_t delayTime = 0);
36 void PostVoidSyncTask(Task&& task, const std::string& name = "ssmTask");
37 void PostTask(Task&& task, const std::string& name, int64_t delayTime = 0);
71 void AddExportTask(std::string taskName, Task task);
75 std::unordered_map<std::string, Task> exportFuncMap_; // will used in OS_SceneSession
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/
H A Dtask_executor.h24 using Task = std::function<void()>;
38 TaskId Execute(Task task) in Execute()
43 TaskId Schedule(Duration delay, Task task) in Schedule()
48 TaskId Schedule(Task task, Duration interval) in Schedule()
53 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule()
58 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule()

Completed in 10 milliseconds

12345678910>>...12