Home
last modified time | relevance | path

Searched refs:taskGroup (Results 1 – 18 of 18) sorted by relevance

/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtaskpool.cpp387 …if (taskGroup->groupState_ == ExecuteState::NOT_FOUND || taskGroup->groupState_ == ExecuteState::F… in ExecuteGroup()
400 if (taskGroup->taskNum_ == 0) { in ExecuteGroup()
406 taskGroup->currentGroupInfo_ = nullptr; in ExecuteGroup()
410 taskGroup->currentGroupInfo_ = groupInfo; in ExecuteGroup()
411 … for (auto iter = taskGroup->taskRefs_.begin(); iter != taskGroup->taskRefs_.end(); iter++) { in ExecuteGroup()
544 if (taskGroup == nullptr || taskGroup->currentGroupInfo_ == nullptr) { in UpdateGroupInfoByResult()
550 auto groupInfo = taskGroup->currentGroupInfo_; in UpdateGroupInfoByResult()
577 auto iter = taskGroup->taskIds_.begin(); in UpdateGroupInfoByResult()
585 taskGroup->groupState_ = ExecuteState::FINISHED; in UpdateGroupInfoByResult()
589 taskGroup->currentGroupInfo_ = nullptr; in UpdateGroupInfoByResult()
[all …]
H A Dtask_manager.cpp617 if (taskGroup == nullptr) { in CancelTask()
1507 if (taskGroup == nullptr) { in AddTask()
1511 taskGroup->taskRefs_.push_back(taskRef); in AddTask()
1512 taskGroup->taskNum_++; in AddTask()
1513 taskGroup->taskIds_.push_back(taskId); in AddTask()
1545 if (taskGroup == nullptr) { in CancelGroup()
1553 …if (taskGroup->currentGroupInfo_ == nullptr || taskGroup->groupState_ == ExecuteState::NOT_FOUND || in CancelGroup()
1562 taskGroup->CancelPendingGroup(env); in CancelGroup()
1563 if (taskGroup->currentGroupInfo_->finishedTaskNum != taskGroup->taskNum_) { in CancelGroup()
1567 if (taskGroup->currentGroupInfo_->finishedTaskNum == taskGroup->taskNum_) { in CancelGroup()
[all …]
H A Dtaskpool.h62 static napi_value ExecuteGroup(napi_env env, napi_value taskGroup, Priority priority);
H A Dtask_manager.h256 void StoreTaskGroup(uint64_t groupId, TaskGroup* taskGroup);
/ohos5.0/docs/zh-cn/application-dev/arkts-utils/
H A Dmulti-time-consuming-tasks.md58 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
59 taskGroup.addTask(new taskpool.Task(loadPicture, 30));
60 taskGroup.addTask(new taskpool.Task(loadPicture, 20));
61 taskGroup.addTask(new taskpool.Task(loadPicture, 10));
62 taskpool.execute(taskGroup).then((ret: object) => {
H A Dthread_communication.md53 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
54 taskGroup.addTask(new taskpool.Task(loadPicture, 30));
55 taskGroup.addTask(new taskpool.Task(loadPicture, 20));
56 taskGroup.addTask(new taskpool.Task(loadPicture, 10));
57 taskpool.execute(taskGroup).then((ret: IconItemSource[][]) => {
H A Darkts-collections-introduction.md41 let taskGroup = new taskpool.TaskGroup();
46 taskGroup.addTask(add, arr, lock);
48 taskpool.execute(taskGroup).then(() => {
/ohos5.0/docs/en/application-dev/arkts-utils/
H A Dmulti-time-consuming-tasks.md58 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
59 taskGroup.addTask(new taskpool.Task(loadPicture, 30));
60 taskGroup.addTask(new taskpool.Task(loadPicture, 20));
61 taskGroup.addTask(new taskpool.Task(loadPicture, 10));
62 taskpool.execute(taskGroup).then((ret: object) => {
H A Dthread_communication.md53 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
54 taskGroup.addTask(new taskpool.Task(loadPicture, 30));
55 taskGroup.addTask(new taskpool.Task(loadPicture, 20));
56 taskGroup.addTask(new taskpool.Task(loadPicture, 10));
57 taskpool.execute(taskGroup).then((ret: IconItemSource[][]) => {
H A Darkts-collections-introduction.md41 let taskGroup = new taskpool.TaskGroup();
46 taskGroup.addTask(add, arr, lock);
48 taskpool.execute(taskGroup).then(() => {
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/
H A Dtask_registry.cpp47 …std::shared_ptr<ITaskGroup> taskGroup = [delayTask, &name, func = std::move(func), serial, pool = … in RegisterTaskGroup() local
56 handle = taskGroup->GetHandle(); in RegisterTaskGroup()
57 registry_.emplace(handle, taskGroup); in RegisterTaskGroup()
/ohos5.0/docs/zh-cn/application-dev/performance/
H A Dthread_memory_shared.md57 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
61 taskGroup.addTask(new taskpool.Task(atomicsProcess, int32Array));
63 taskGroup.addTask(new taskpool.Task(normalProcess, int32Array));
66 taskpool.execute(taskGroup).then(() => {
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest_taskpool.cpp465 TaskGroup taskGroup; variable
474 TaskGroup taskGroup; variable
475 taskGroup.NotifyGroupTask(env);
485 TaskGroup taskGroup; variable
874 TaskGroup taskGroup; variable
884 TaskGroup taskGroup; variable
894 TaskGroup taskGroup; variable
897 taskGroup.NotifyGroupTask(env);
909 taskGroup->groupId_ = groupId;
925 taskGroup->groupId_ = groupId;
[all …]
H A Dtest.h43 static napi_value ExecuteGroup(napi_env env, napi_value taskGroup);
H A Dtest.cpp165 napi_value NativeEngineTest::ExecuteGroup(napi_env env, napi_value taskGroup) in ExecuteGroup() argument
167 return TaskPool::ExecuteGroup(env, taskGroup, Priority::DEFAULT); in ExecuteGroup()
/ohos5.0/docs/en/application-dev/performance/
H A Dthread_memory_shared.md57 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
61 taskGroup.addTask(new taskpool.Task(atomicsProcess, int32Array));
63 taskGroup.addTask(new taskpool.Task(normalProcess, int32Array));
66 taskpool.execute(taskGroup).then(() => {
/ohos5.0/docs/zh-cn/application-dev/reference/apis-arkts/
H A Djs-apis-taskpool.md1912 let taskGroup = new taskpool.TaskGroup();
1943 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup(taskGroupName);
1944 let name: string = taskGroup.name;
1982 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
1983 taskGroup.addTask(printArgs, 100); // 100: test number
2021 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
2023 taskGroup.addTask(task);
/ohos5.0/docs/en/application-dev/reference/apis-arkts/
H A Djs-apis-taskpool.md1916 let taskGroup = new taskpool.TaskGroup();
1947 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup(taskGroupName);
1948 let name: string = taskGroup.name;
1986 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
1987 taskGroup.addTask(printArgs, 100); // 100: test number
2025 let taskGroup: taskpool.TaskGroup = new taskpool.TaskGroup();
2027 taskGroup.addTask(task);