/ohos5.0/docs/zh-cn/device-dev/kernel/ |
H A D | kernel-mini-basic-ipc-mutex.md | 126 printf("task2 try to get mutex, wait forever.\n"); 134 printf("task2 resumed and post the g_testMux\n"); 144 TSK_INIT_PARAM_S task2 = { 0 }; 166 task2.pfnTaskEntry = (TSK_ENTRY_FUNC)ExampleMutexTask2; 167 task2.pcName = "MutexTsk2"; 169 task2.usTaskPrio = 4; 170 ret = LOS_TaskCreate(&taskId02, &task2); 172 printf("task2 create failed.\n"); 189 task2 try to get mutex, wait forever. 190 task2 get mutex g_testMux and suspend 100 ticks. [all …]
|
H A D | kernel-small-basic-trans-mutex.md | 152 dprintf("task2 try to get mutex, wait forever.\n"); 161 dprintf("task2 resumed and post the g_testMux\n"); 171 TSK_INIT_PARAM_S task2; 192 memset(&task2, 0, sizeof(TSK_INIT_PARAM_S)); 194 task2.pcName = "MutexTsk2"; 196 task2.usTaskPrio = 4; 197 ret = LOS_TaskCreate(&g_testTaskId02, &task2); 199 dprintf("task2 create failed.\n"); 216 task2 try to get mutex, wait forever. 217 task2 get mutex g_testMux and suspend 100 ticks. [all …]
|
H A D | kernel-small-basic-trans-semaphore.md | 190 TSK_INIT_PARAM_S task2; 211 (VOID)memset_s(&task2, sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S)); 212 task2.pfnTaskEntry = (TSK_ENTRY_FUNC)ExampleSemTask2; 213 task2.pcName = "TestTask2"; 214 task2.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE; 215 task2.usTaskPrio = TASK_PRIO_HI; 216 ret = LOS_TaskCreate(&g_testTaskId02, &task2); 218 dprintf("task2 create failed.\n");
|
H A D | kernel-mini-basic-ipc-sem.md | 163 TSK_INIT_PARAM_S task2 = { 0 }; 185 task2.pfnTaskEntry = (TSK_ENTRY_FUNC)ExampleSemTask2; 186 task2.pcName = "TestTask2"; 187 task2.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE; 188 task2.usTaskPrio = 4; 189 ret = LOS_TaskCreate(&taskId2, &task2); 191 printf("task2 create failed.\n");
|
H A D | kernel-mini-basic-ipc-queue.md | 189 UINT32 task2; 209 ret = LOS_TaskCreate(&task2, &taskParam2); 211 printf("create task2 failed, error: %x\n", ret);
|
H A D | kernel-small-basic-trans-queue.md | 190 UINT32 task1, task2; 215 ret = LOS_TaskCreate(&task2, &initParam); 217 dprintf("create task2 failed, error: %x\n", ret);
|
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/ |
H A D | task_ctx_test.cpp | 67 SCPUEUTask *task2 = new SCPUEUTask(nullptr, task1, 0, QoS()); variable 69 task2->SetQos(qos2); 70 EXPECT_EQ(task2->qos, static_cast<int>(qos_user_interactive)); 72 delete task2;
|
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/ |
H A D | ut_core_test.cpp | 65 SCPUEUTask *task2 = new SCPUEUTask(nullptr, task1, 0, QoS()); variable 67 task2->SetQos(qos); 68 EXPECT_EQ(task2->qos, static_cast<int>(qos_user_interactive)); 70 delete task2;
|
H A D | ut_core.cpp | 64 SCPUEUTask *task2 = new SCPUEUTask(nullptr, task1, 0, QoS()); variable 66 task2->SetQos(qos); 67 EXPECT_EQ(task2->qos, static_cast<int>(qos_user_interactive)); 69 delete task2;
|
/ohos5.0/docs/en/device-dev/kernel/ |
H A D | kernel-mini-basic-ipc-mutex.md | 126 printf("task2 try to get mutex, wait forever.\n"); 134 printf("task2 resumed and post the g_testMux\n"); 144 TSK_INIT_PARAM_S task2 = { 0 }; 166 task2.pfnTaskEntry = (TSK_ENTRY_FUNC)ExampleMutexTask2; 167 task2.pcName = "MutexTsk2"; 169 task2.usTaskPrio = 4; 170 ret = LOS_TaskCreate(&taskId02, &task2); 172 printf("task2 create failed.\n"); 189 task2 try to get mutex, wait forever. 190 task2 get mutex g_testMux and suspend 100 ticks. [all …]
|
H A D | kernel-small-basic-trans-mutex.md | 159 dprintf("task2 try to get mutex, wait forever.\n"); 168 dprintf("task2 resumed and post the g_testMux\n"); 178 TSK_INIT_PARAM_S task2; 199 memset(&task2, 0, sizeof(TSK_INIT_PARAM_S)); 201 task2.pcName = "MutexTsk2"; 203 task2.usTaskPrio = 4; 204 ret = LOS_TaskCreate(&g_testTaskId02, &task2); 206 dprintf("task2 create failed.\n"); 223 task2 try to get mutex, wait forever. 224 task2 get mutex g_testMux and suspend 100 ticks. [all …]
|
H A D | kernel-small-basic-trans-semaphore.md | 196 TSK_INIT_PARAM_S task2; 217 (VOID)memset_s(&task2, sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S)); 218 task2.pfnTaskEntry = (TSK_ENTRY_FUNC)ExampleSemTask2; 219 task2.pcName = "TestTask2"; 220 task2.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE; 221 task2.usTaskPrio = TASK_PRIO_HI; 222 ret = LOS_TaskCreate(&g_testTaskId02, &task2); 224 dprintf("task2 create failed.\n");
|
H A D | kernel-mini-basic-ipc-sem.md | 163 TSK_INIT_PARAM_S task2 = { 0 }; 185 task2.pfnTaskEntry = (TSK_ENTRY_FUNC)ExampleSemTask2; 186 task2.pcName = "TestTask2"; 187 task2.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE; 188 task2.usTaskPrio = 4; 189 ret = LOS_TaskCreate(&taskId2, &task2); 191 printf("task2 create failed.\n");
|
/ohos5.0/docs/zh-cn/application-dev/ffrt/ |
H A D | ffrt-overview.md | 71 task2(IN A); 83 - task1 与task2/task3 构成Producer-Consumer 依赖,即:task2/task3 需要等到task1 写完A之后才能读A 84 - task2/task3 与task4 构成Consumer-Producer 依赖,即:task4 需要等到task2/task3 读完A之后才能写A
|
/ohos5.0/foundation/multimedia/media_foundation/test/unittest/ |
H A D | TestSynchronizer.cpp | 42 task2 = std::make_shared<Task>("workTask2"); in SetUp() 53 std::shared_ptr<Task> task2; member in OHOS::Media::Test::TestSynchronizer 125 task2->RegisterHandler([this, syncId, expect] { in __anon43a178830902() 129 task2->Start();
|
/ohos5.0/docs/zh-cn/application-dev/arkts-utils/ |
H A D | taskpool-introduction.md | 165 let task2: taskpool.Task = new taskpool.Task(testPromise1, 1, 2); 176 taskpool.execute(task2).then((d:object)=>{ 177 console.info("task2 res is: " + d); 179 console.info("task2 catch e: " + e); 358 let task2: taskpool.Task = new taskpool.Task(testPromiseError1); 366 taskpool.execute(task2).then((d:object)=>{ 367 console.info("task2 res is: " + d); 369 console.info("task2 catch e: " + e);
|
H A D | sync-task-development.md | 45 let task2: taskpool.Task = new taskpool.Task(taskpoolFunc, res1); 46 let res2: number = await taskpool.execute(task2) as number;
|
/ohos5.0/docs/zh-cn/application-dev/reference/apis-arkts/ |
H A D | js-apis-taskpool.md | 299 taskGroup2.addTask(task2); 632 taskpool.execute(task2); 854 taskArray.push(task2); 1421 task1.addDependency(task2); 1422 task2.addDependency(task3); 1480 task1.addDependency(task2); 1481 task2.addDependency(task3); 1484 task1.removeDependency(task2); 1485 task2.removeDependency(task3); 1645 taskpool.execute(task2).then(()=>{ [all …]
|
/ohos5.0/foundation/multimedia/media_foundation/tests/unittest/osal/ |
H A D | task_func_unit_test.cpp | 57 std::shared_ptr<Task> task2 = nullptr; member in OHOS::Media::MetaFuncUT::TaskInnerUnitTest 84 task2 = std::make_shared<Task>("workTask2"); in SetUp() 101 task2 = nullptr; in TearDown() 133 task2->RegisterJob([]() { in __anon797004620202() 146 bool rtv = task2->IsTaskRunning();
|
/ohos5.0/base/powermgr/power_manager/test/apitest/inner_api/ffrt/src/ |
H A D | ffrt_utils_test.cpp | 66 FFRTTask task2 = [&]() { in __anone73078890402() variable 76 FFRTUtils::SubmitQueueTasks({task1, task2, task3}, queue); // submit batch tasks to a queue 182 FFRTTask task2 = [&mutex]() { in __anone73078890b02() variable 188 FFRTUtils::SubmitTaskSync(task2);
|
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
H A D | test.cpp | 506 Task* task2 = new Task(); in StoreTaskDependency() local 508 task2->env_ = env; in StoreTaskDependency() 514 uint64_t id5 = task2->taskId_; in StoreTaskDependency() 515 uint64_t id6 = task2->taskId_ + MAX_TIMEOUT_TIME; in StoreTaskDependency() 586 Task* task2 = new Task(); in ReleaseTaskData() local 587 task2->taskId_ = reinterpret_cast<uint64_t>(task2); in ReleaseTaskData() 588 task2->isMainThreadTask_ = true; in ReleaseTaskData() 589 taskManager.ReleaseCallBackInfo(task2); in ReleaseTaskData() 590 task2->isMainThreadTask_ = false; in ReleaseTaskData() 591 taskManager.ReleaseCallBackInfo(task2); in ReleaseTaskData() [all …]
|
/ohos5.0/docs/en/application-dev/arkts-utils/ |
H A D | taskpool-introduction.md | 165 let task2: taskpool.Task = new taskpool.Task(testPromise1, 1, 2); 176 taskpool.execute(task2).then((d:object)=>{ 177 console.info("task2 res is: " + d); 179 console.info("task2 catch e: " + e); 358 let task2: taskpool.Task = new taskpool.Task(testPromiseError1); 366 taskpool.execute(task2).then((d:object)=>{ 367 console.info("task2 res is: " + d); 369 console.info("task2 catch e: " + e);
|
/ohos5.0/foundation/arkui/ace_engine_lite/frameworks/native_engine/async/ |
H A D | js_async_work.cpp | 97 auto task2 = [handler, data]() { in DispatchAsyncWorkInner() local 100 return postUITask_(task2); in DispatchAsyncWorkInner()
|
/ohos5.0/base/request/request/services/src/manage/scheduler/qos/ |
H A D | apps.rs | 324 let task2 = Task::new(2, Mode::FrontEnd, 1); in ut_task_partial_ord() localVariable 327 assert!(task1 < task2); in ut_task_partial_ord() 330 assert!(task2 < task3); in ut_task_partial_ord() 331 assert!(task2 < task4); in ut_task_partial_ord()
|
/ohos5.0/base/powermgr/power_manager/test/unittest/src/ |
H A D | running_lock_timer_handler_test.cpp | 161 std::function<void()> task2 = [&]() { in __anon9f4458ee0502() variable 165 runningLockTimerHandler->RegisterRunningLockTimer(token2, task2, TIMEOUT_MS);
|