Home
last modified time | relevance | path

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

/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask.cpp39 Task::Task(napi_env env, TaskType taskType, std::string name) : env_(env), taskType_(taskType), name_(name) {} in Task() function in Commonlibrary::Concurrent::TaskPoolModule::Task
41 napi_value Task::TaskConstructor(napi_env env, napi_callback_info cbinfo) in TaskConstructor()
77 Task* task = GenerateTask(env, thisVar, func, name, args, argc); in TaskConstructor()
82 napi_add_env_cleanup_hook(env, Task::CleanupHookFunc, task); in TaskConstructor()
87 napi_value Task::LongTaskConstructor(napi_env env, napi_callback_info cbinfo) in LongTaskConstructor()
90 Task* task; in LongTaskConstructor()
96 void Task::TaskDestructor(napi_env env, void* data, [[maybe_unused]] void* hint) in TaskDestructor()
98 Task* task = static_cast<Task*>(dat in TaskDestructor()
[all...]
H A Dtask.h77 class Task { class
79 Task(napi_env env, TaskType taskType, std::string name);
80 Task() = default;
81 ~Task() = default;
103 static Task* GenerateTask(napi_env env, napi_value task, napi_value func,
105 static Task* GenerateFunctionTask(napi_env env, napi_value func, napi_value* args, size_t argc, TaskType type);
160 Task(const Task &) = delete;
161 Task& operator=(const Task
[all...]
H A Dtaskpool.h40 static void HandleTaskResultCallback(Task* task);
60 static void UpdateGroupInfoByResult(napi_env env, Task* task, napi_value res, bool success);
61 static void ExecuteTask(napi_env env, Task* task, Priority priority = Priority::DEFAULT);
64 static void TriggerTask(Task* task);
65 static void TriggerTimer(napi_env env, Task* task, int32_t period);
68 Task* &task);
70 Task* &task);
H A Dtask_manager.h61 void StoreTask(uint64_t taskId, Task* task);
63 Task* GetTask(uint64_t taskId);
68 void CancelSeqRunnerTask(napi_env env, Task* task);
69 void ReleaseTaskData(napi_env env, Task* task, bool shouldDeleteTask = true);
105 napi_value NotifyCallbackExecute(napi_env env, TaskResultInfo* resultInfo, Task* task);
136 void ReleaseCallBackInfo(Task* task);
179 // <taskId, Task>
180 std::unordered_map<uint64_t, Task*> tasks_ {};
260 void AddTaskToSeqRunner(uint64_t seqRunnerId, Task* task);
261 bool TriggerSeqRunner(napi_env env, Task* lastTas
[all...]
H A Dworker.h81 static void NotifyTaskResult(napi_env env, Task* task, napi_value result);
82 static void NotifyHandleTaskResult(Task* task);
178 bool InitTaskPoolFunc(napi_env env, napi_value func, Task* task);
180 void UpdateLongTaskInfo(Task* task);
187 static void HandleFunctionException(napi_env env, Task* task);
H A Dtaskpool.cpp37 napi_define_class(env, "Task", NAPI_AUTO_LENGTH, Task::TaskConstructor, nullptr, 0, nullptr, &taskClass); in InitTaskPool()
39 napi_define_class(env, "LongTask", NAPI_AUTO_LENGTH, Task::LongTaskConstructor, in InitTaskPool()
42 napi_define_class(env, "GenericsTask", NAPI_AUTO_LENGTH, Task::TaskConstructor, in InitTaskPool()
45 napi_create_function(env, "isCanceled", NAPI_AUTO_LENGTH, Task::IsCanceled, NULL, &isCanceledFunc); in InitTaskPool()
48 napi_create_function(env, "sendData", NAPI_AUTO_LENGTH, Task::SendData, NULL, &sendDataFunc); in InitTaskPool()
84 DECLARE_NAPI_PROPERTY("Task", taskClass), in InitTaskPool()
239 Task* task = nullptr; in Execute()
261 Task* task = Task in Execute()
[all...]
H A Dtask_group.cpp99 Task* task = nullptr; in AddTask()
115 Task* task = Task::GenerateFunctionTask(env, args[0], args + 1, argc - 1, TaskType::GROUP_FUNCTION_TASK); in AddTask()
121 napi_wrap(env, napiTask, task, Task::TaskDestructor, nullptr, nullptr); in AddTask()
154 Task* task = nullptr; in NotifyGroupTask()
H A Dworker.cpp394 Task* task = TaskManager::GetInstance().GetTask(taskInfo.first); in PerformTask()
417 // tag for trace parse: Task Perform in PerformTask()
418 std::string strTrace = "Task Perform: name : " + task->name_ + ", taskId : " + std::to_string(task->taskId_) in PerformTask()
457 void Worker::NotifyTaskResult(napi_env env, Task* task, napi_value result) in NotifyTaskResult()
479 void Worker::NotifyHandleTaskResult(Task* task) in NotifyHandleTaskResult()
514 Task* task = static_cast<Task*>(data); in TaskResultCallback()
556 bool Worker::InitTaskPoolFunc(napi_env env, napi_value func, Task* task) in InitTaskPoolFunc()
601 void Worker::UpdateLongTaskInfo(Task* task) in UpdateLongTaskInfo()
621 void Worker::HandleFunctionException(napi_env env, Task* tas
[all...]
H A Dsequence_runner.h48 std::queue<Task*> seqRunnerTasks_ {};
H A Dtask_manager.cpp596 Task* task = GetTask(taskId); in CancelTask()
644 void TaskManager::CancelSeqRunnerTask(napi_env env, Task *task) in CancelSeqRunnerTask()
746 Task* task = GetTask(taskId); in EnqueueTaskId()
950 auto task = reinterpret_cast<Task*>(taskId); in DecreaseRefCount()
962 napi_value TaskManager::NotifyCallbackExecute(napi_env env, TaskResultInfo* resultInfo, Task* task) in NotifyCallbackExecute()
1302 void TaskManager::ReleaseTaskData(napi_env env, Task* task, bool shouldDeleteTask) in ReleaseTaskData()
1350 void TaskManager::ReleaseCallBackInfo(Task* task) in ReleaseCallBackInfo()
1394 void TaskManager::StoreTask(uint64_t taskId, Task* task) in StoreTask()
1406 Task* TaskManager::GetTask(uint64_t taskId) in GetTask()
1489 Task* tas in ReleaseTaskGroupData()
[all...]
H A Dsequence_runner.cpp128 Task* task = nullptr; in Execute()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dmod.rs68 pub(crate) struct Task(pub(crate) RawTask);
70 unsafe impl Send for Task {}
71 unsafe impl Sync for Task {}
74 impl Task { impls
91 pub(crate) unsafe fn from_raw(ptr: NonNull<Header>) -> Task {
92 Task(RawTask::form_raw(ptr))
96 impl Task { impls
102 ) -> (Task, JoinHandle<T::Output>)
108 let raw = Task::create_raw_task::<T, S>(builder, scheduler, task, virtual_table_type);
111 (Task(ra
[all...]
H A Dtask_handle.rs27 use crate::task::Task;
255 fn to_task(&self) -> Task { in to_task()
256 unsafe { Task::from_raw(self.header().into()) } in to_task()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/ffrt/
H A Dspawner.rs23 use crate::task::{JoinHandle, Task, TaskBuilder, VirtualTableType};
25 pub(crate) fn ffrt_submit(t: Task, builder: &TaskBuilder) {
28 match (*(data as *mut Task)).0.run() { in exec_future()
37 drop(Box::from_raw(data as *mut Task)); in exec_drop()
52 let t: Box<Task> = Box::new(t);
72 let (task, join_handle) = Task::create_task(builder, scheduler, task, VirtualTableType::Ffrt); in spawn()
/commonlibrary/c_utils/base/include/
H A Dthread_pool.h38 typedef std::function<void()> Task; typedef in OHOS::ThreadPool
73 void AddTask(const Task& f);
103 Task ScheduleTask(); // fetch a task from the queue and execute it
111 std::deque<Task> tasks_;
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dqueue.rs26 use crate::task::{Header, Task};
78 pub(crate) fn pop_front(&self) -> Option<Task> {
83 pub(crate) fn push_back(&self, task: Task, global: &GlobalQueue) {
88 pub(crate) fn steal_into(&self, dst: &LocalQueue) -> Option<Task> {
131 buffer: Box<[UnsafeCell<MaybeUninit<Task>>]>,
204 pub(crate) fn pop_front(&self) -> Option<Task> {
267 pub(crate) fn push_back(&self, mut task: Task, global: &GlobalQueue) {
298 task: Task,
301 ) -> Result<(), Task> {
341 pub(crate) fn steal_into(&self, dst: &LocalQueue) -> Option<Task> {
[all...]
H A Dasync_pool.rs32 use crate::task::{JoinHandle, Task, TaskBuilder, VirtualTableType};
60 fn schedule(&self, task: Task, lifo: bool) { in schedule()
182 fn enqueue_under_ctx(&self, mut task: Task, worker_ctx: &WorkerContext, lifo: bool) -> bool { in enqueue_under_ctx()
214 pub(crate) fn enqueue(&self, task: Task, lifo: bool) -> bool {
229 fn get_task_from_queues(&self, worker_inner: &mut worker::Inner) -> Option<Task> { in get_task_from_queues()
264 fn get_task_from_searching(&self, worker_inner: &mut worker::Inner) -> Option<Task> { in get_task_from_searching()
295 ) -> Option<Task> {
312 fn steal(&self, destination: &LocalQueue) -> Option<Task> { in steal()
501 Task::create_task(builder, exe_scheduler, task, VirtualTableType::Ylong);
555 let raw_task = Task
[all...]
H A Dblocking_pool.rs141 /// Task queue
142 queue: VecDeque<Task>,
166 type Task = task::Task; types
202 let (task, handle) = Task::create_task(builder, scheduler, task, VirtualTableType::Ylong);
207 fn spawn(&self, task: Task) { in spawn()
401 // Task won't be polled again after finished in poll()
H A Dmod.rs29 use crate::task::{JoinHandle, Task, TaskBuilder};
51 fn schedule(&self, task: Task, lifo: bool); in schedule()
57 fn schedule(&self, _task: Task, _lifo: bool) { in schedule()
H A Dworker.rs24 use crate::task::Task;
127 pub(crate) lifo: RefCell<Option<Task>>,
162 fn get_task(&self, inner: &mut Inner, worker_ctx: &WorkerContext) -> Option<Task> { in get_task()
H A Dcurrent_thread.rs27 use crate::task::{JoinHandle, Task, TaskBuilder, VirtualTableType};
48 pub(crate) inner: Mutex<VecDeque<Task>>,
59 fn schedule(&self, task: Task, _lifo: bool) { in schedule()
73 fn pop(&self) -> Option<Task> { in pop()
256 let (task, handle) = Task::create_task(builder, scheduler, task, VirtualTableType::Ylong);
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest_taskpool.cpp48 napi_create_function(env, funcName.c_str(), funcName.size(), Task::TaskConstructor, nullptr, &cb); in GeneratorTask()
86 Task* task = Task::GenerateTask(env, thisValue, func, taskName, args, argc); in CreateTaskObject()
98 auto obj = reinterpret_cast<Task*>(data); in CreateTaskObject()
109 Task* task = nullptr; in CreateNullTaskObject()
113 auto obj = reinterpret_cast<Task*>(data); in CreateNullTaskObject()
157 Task* task = taskManager.GetTask(taskId); in HWTEST_F()
287 Task* task = new Task(); in HWTEST_F()
299 Task* tas in HWTEST_F()
[all...]
H A Dtest.cpp182 Task* task = reinterpret_cast<Task*>(handle->data); in UpdateGroupInfoByResult()
329 Task* task = new Task(); in CancelTask()
364 Task* task = new Task(); in NotifyWorkerIdle()
381 Task* task = new Task(); in EnqueueTaskId()
402 Task* task = new Task(); in GetTaskByPriority()
[all...]
/commonlibrary/c_utils/base/src/
H A Dthread_pool.cpp74 void ThreadPool::AddTask(const Task &f) in AddTask()
96 ThreadPool::Task ThreadPool::ScheduleTask() in ScheduleTask()
103 Task task; in ScheduleTask()
123 Task task = ScheduleTask(); in WorkInThread()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/
H A Dcore.rs25 use crate::task::{Task, VirtualTableType};
199 let raw_task = Task::create_raw_task( in spawn_task_ffrt()
206 let task = Task(raw_task); in spawn_task_ffrt()

Completed in 21 milliseconds