Searched refs:taskPool (Results 1 - 10 of 10) sorted by relevance
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | task_pool.cpp | 24 TaskPool *taskPool = new (std::nothrow) TaskPoolImpl(maxThreads, minThreads); in Create() local
25 if (taskPool == nullptr) { in Create()
31 return taskPool; in Create()
34 void TaskPool::Release(TaskPool *&taskPool) in Release() argument
36 if (taskPool != nullptr) { in Release()
37 delete taskPool; in Release()
38 taskPool = nullptr; in Release()
|
| H A D | runtime_context_impl.cpp | 368 TaskPool *taskPool = TaskPool::Create(MAX_TP_THREADS, MIN_TP_THREADS, errCode);
369 if (taskPool == nullptr) {
373 errCode = taskPool->Start();
375 taskPool->Release(taskPool);
379 taskPool_ = taskPool;
|
| /foundation/arkui/ace_engine/frameworks/core/components/custom_paint/ |
| H A D | render_custom_paint.cpp | 46 const auto& taskPool = customPaint->GetTaskPool(); in Update() local
47 if (taskPool) { in Update()
48 taskPool->SetRenderNode(AceType::WeakClaim(this)); in Update()
49 pool_ = taskPool; in Update()
50 std::copy(taskPool->GetTasks().begin(), taskPool->GetTasks().end(), std::back_inserter(tasks_)); in Update()
51 taskPool->ClearTasks(); in Update()
59 canvasOnReadyEvent_ = taskPool->GetOnReadyEvent(); in Update()
|
| /foundation/systemabilitymgr/samgr_lite/samgr/source/ |
| H A D | task_manager.c | 52 TaskPool *taskPool = (TaskPool *)SAMGR_Malloc(sizeof(TaskPool) + sizeof(ThreadId) * size);
in SAMGR_CreateFixedTaskPool() local
53 if (taskPool == NULL) {
in SAMGR_CreateFixedTaskPool()
59 (void)memset_s(taskPool, sizeof(TaskPool) + sizeof(ThreadId) * size, 0,
in SAMGR_CreateFixedTaskPool()
61 taskPool->queueId = queueId;
in SAMGR_CreateFixedTaskPool()
62 taskPool->stackSize = config->stackSize;
in SAMGR_CreateFixedTaskPool()
63 taskPool->priority = (uint8)config->priority;
in SAMGR_CreateFixedTaskPool()
64 taskPool->size = size;
in SAMGR_CreateFixedTaskPool()
65 taskPool->top = 0;
in SAMGR_CreateFixedTaskPool()
66 taskPool->ref = 1;
in SAMGR_CreateFixedTaskPool()
67 return taskPool;
in SAMGR_CreateFixedTaskPool()
[all...] |
| H A D | service.c | 33 impl->taskPool = NULL;
in SAMGR_CreateServiceImpl()
71 Identity id = {impl->serviceId, INVALID_INDEX, (impl->taskPool != NULL) ? impl->taskPool->queueId : NULL};
in DEFAULT_Initialize()
120 Identity id = {service->serviceId, INVALID_INDEX, (service->taskPool != NULL) ? service->taskPool->queueId : NULL};
in DEFAULT_StopService()
152 if (serviceImpl->taskPool != NULL) {
in DEFAULT_GetFeatureId()
153 identity.queueId = serviceImpl->taskPool->queueId;
in DEFAULT_GetFeatureId()
|
| H A D | samgr_lite.c | 213 SAMGR_StartTaskPool(serviceImpl->taskPool, name);
in InitializeAllServices()
269 SAMGR_ReleaseTaskPool(serviceImpl->taskPool);
in UnregisterService()
436 if (service->taskPool != NULL) {
in AddTaskPool()
454 service->taskPool = samgr->sharedPool[pos];
in AddTaskPool()
455 if (SAMGR_ReferenceTaskPool(service->taskPool) == NULL) {
in AddTaskPool()
463 service->taskPool = GetSpecifiedTaskPool(cfg);
in AddTaskPool()
464 if (service->taskPool != NULL) {
in AddTaskPool()
469 service->taskPool = SAMGR_CreateFixedTaskPool(cfg, name, SINGLE_SIZE);
in AddTaskPool()
475 if (service->taskPool == NULL) {
in AddTaskPool()
476 HILOG_ERROR(HILOG_MODULE_SAMGR, "Service<name:%s, flag:%hhu> create taskPool faile in AddTaskPool()
563 TaskPool *taskPool = SAMGR_ReferenceTaskPool(impl->taskPool); GetSpecifiedTaskPool() local
[all...] |
| H A D | service_impl.h | 50 TaskPool *taskPool;
member
|
| /foundation/CastEngine/castengine_wifi_display/tests/unittest/event/ |
| H A D | event_unit_test.cpp | 514 std::shared_ptr<TaskPool> taskPool = std::make_shared<TaskPool>(); in HWTEST_F() local
515 EXPECT_NE(taskPool, nullptr); in HWTEST_F()
517 taskPool->SetMaxTaskNum(1000); in HWTEST_F()
518 auto ret = taskPool->GetMaxTaskNum(); in HWTEST_F()
521 ret = taskPool->Start(100); in HWTEST_F()
524 taskPool->SetTimeoutInterval(1000); in HWTEST_F()
526 taskPool->Stop(); in HWTEST_F()
528 taskPool->PushTask(bindedTask); in HWTEST_F()
530 ret = taskPool->GetTaskNum(); in HWTEST_F()
|
| /foundation/arkui/ace_engine/frameworks/core/components/xcomponent/ |
| H A D | render_xcomponent.cpp | 225 const auto& taskPool = xcomponent->GetTaskPool(); in Update() local
226 if (taskPool) { in Update()
227 taskPool->SetRenderNode(AceType::WeakClaim(this)); in Update()
228 pool_ = taskPool; in Update()
229 tasks_ = std::list<TaskFunction>(taskPool->GetTasks().begin(), taskPool->GetTasks().end()); in Update()
230 taskPool->ClearTasks(); in Update()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | task_pool.h | 46 static void Release(TaskPool *&taskPool);
|
Completed in 6 milliseconds