Searched refs:TaskPool (Results 1 - 16 of 16) sorted by relevance
| /foundation/CastEngine/castengine_wifi_display/services/event/ |
| H A D | taskpool.cpp | 20 TaskPool::TaskPool() in TaskPool() function in OHOS::Sharing::TaskPool
25 TaskPool::~TaskPool() in ~TaskPool()
33 int32_t TaskPool::Start(int32_t threadsNum) in Start()
49 threads_.push_back(std::thread(&TaskPool::TaskMainWorker, this)); in Start()
57 void TaskPool::Stop() in Stop()
71 void TaskPool::PushTask(std::packaged_task<BindedTask> &task) in PushTask()
86 bool TaskPool::IsOverload() const in IsOverload()
91 void TaskPool
[all...] |
| H A D | taskpool.h | 35 class TaskPool : public NoCopyable { class
40 TaskPool();
41 ~TaskPool();
|
| H A D | event_manager.h | 38 public TaskPool {
|
| /foundation/systemabilitymgr/samgr_lite/samgr/source/ |
| H A D | task_manager.h | 37 typedef struct TaskPool TaskPool;
typedef
38 struct TaskPool {
struct
47 TaskPool *SAMGR_CreateFixedTaskPool(const TaskConfig *config, const char *name, uint8 size);
48 int32 SAMGR_StartTaskPool(TaskPool *pool, const char *name);
49 int32 SAMGR_ReleaseTaskPool(TaskPool *pool);
50 TaskPool *SAMGR_ReferenceTaskPool(TaskPool *pool);
|
| H A D | task_manager.c | 40 TaskPool *SAMGR_CreateFixedTaskPool(const TaskConfig *config, const char *name, uint8 size)
in SAMGR_CreateFixedTaskPool()
52 TaskPool *taskPool = (TaskPool *)SAMGR_Malloc(sizeof(TaskPool) + sizeof(ThreadId) * size);
in SAMGR_CreateFixedTaskPool()
54 HILOG_ERROR(HILOG_MODULE_SAMGR, "Create TaskPool<%s> size:%hu failed!", name, config->queueSize);
in SAMGR_CreateFixedTaskPool()
59 (void)memset_s(taskPool, sizeof(TaskPool) + sizeof(ThreadId) * size, 0,
in SAMGR_CreateFixedTaskPool()
60 sizeof(TaskPool) + sizeof(ThreadId) * size);
in SAMGR_CreateFixedTaskPool()
70 int32 SAMGR_StartTaskPool(TaskPool *pool, const char *name)
in SAMGR_StartTaskPool()
93 int32 SAMGR_ReleaseTaskPool(TaskPool *pool)
in SAMGR_ReleaseTaskPool()
109 TaskPool *SAMGR_ReferenceTaskPoo
[all...] |
| H A D | samgr_lite_inner.h | 59 TaskPool *sharedPool[MAX_POOL_NUM];
|
| H A D | service_impl.h | 50 TaskPool *taskPool;
|
| H A D | samgr_lite.c | 64 static TaskPool *GetSpecifiedTaskPool(TaskConfig *config);
108 (void)memset_s(g_samgrImpl.sharedPool, sizeof(TaskPool *) * MAX_POOL_NUM, 0,
in Init()
109 sizeof(TaskPool *) * MAX_POOL_NUM);
in Init()
541 static TaskPool *GetSpecifiedTaskPool(TaskConfig *config)
in GetSpecifiedTaskPool()
563 TaskPool *taskPool = SAMGR_ReferenceTaskPool(impl->taskPool);
in GetSpecifiedTaskPool()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | task_pool.h | 27 class TaskPool { class
45 static TaskPool *Create(int maxThreads, int minThreads, int &errCode);
46 static void Release(TaskPool *&taskPool);
49 TaskPool() = default;
50 virtual ~TaskPool() {} in ~TaskPool()
51 DISABLE_COPY_ASSIGN_MOVE(TaskPool);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | task_pool.cpp | 22 TaskPool *TaskPool::Create(int maxThreads, int minThreads, int &errCode) in Create()
24 TaskPool *taskPool = new (std::nothrow) TaskPoolImpl(maxThreads, minThreads); in Create()
34 void TaskPool::Release(TaskPool *&taskPool) in Release()
|
| H A D | task_pool_impl.h | 29 class TaskPoolImpl : public TaskPool {
|
| H A D | runtime_context_impl.cpp | 368 TaskPool *taskPool = TaskPool::Create(MAX_TP_THREADS, MIN_TP_THREADS, errCode);
776 TaskPool::Release(taskPool_);
|
| H A D | runtime_context_impl.h | 225 TaskPool *taskPool_;
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | thread_pool_test_stub.cpp | 28 TaskPool::Release(taskPool_); in ~ThreadPoolTestStub()
56 taskPool_ = TaskPool::Create(10, 1, errCode); // 10 is max thread, 1 is min thread in StartThreadIfNeed()
64 TaskPool::Release(taskPool_); in StartThreadIfNeed()
|
| H A D | thread_pool_test_stub.h | 47 TaskPool *taskPool_ = nullptr;
|
| /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()
527 std::packaged_task<TaskPool::BindedTask> bindedTask(testTask); in HWTEST_F()
|
Completed in 7 milliseconds