Searched refs:TaskPool (Results 1 – 16 of 16) sorted by relevance
| /foundation/systemabilitymgr/samgr_lite/samgr/source/ |
| 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); argument
48 int32 SAMGR_StartTaskPool(TaskPool *pool, const char *name);
49 int32 SAMGR_ReleaseTaskPool(TaskPool *pool);
50 TaskPool *SAMGR_ReferenceTaskPool(TaskPool *pool);
|
| 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()
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_ReferenceTaskPool(TaskPool *pool) in SAMGR_ReferenceTaskPool()
|
| D | samgr_lite_inner.h | 59 TaskPool *sharedPool[MAX_POOL_NUM];
|
| D | service_impl.h | 50 TaskPool *taskPool;
|
| 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/CastEngine/castengine_wifi_display/services/event/ |
| 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::TaskMainWorker() in TaskMainWorker()
111 void TaskPool::SetTimeoutInterval(uint32_t ms) in SetTimeoutInterval()
|
| D | taskpool.h | 35 class TaskPool : public NoCopyable {
40 TaskPool();
41 ~TaskPool();
|
| D | event_manager.h | 38 public TaskPool {
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| D | task_pool.h | 27 class TaskPool {
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/ |
| 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()
|
| D | task_pool_impl.h | 29 class TaskPoolImpl : public TaskPool {
|
| D | runtime_context_impl.h | 214 TaskPool *taskPool_;
|
| D | runtime_context_impl.cpp | 365 TaskPool *taskPool = TaskPool::Create(MAX_TP_THREADS, MIN_TP_THREADS, errCode); in PrepareTaskPool()
771 TaskPool::Release(taskPool_); in StopTaskPool()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| 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()
|
| D | thread_pool_test_stub.h | 47 TaskPool *taskPool_ = nullptr;
|
| /foundation/CastEngine/castengine_wifi_display/tests/unittest/event/ |
| D | event_unit_test.cpp | 136 std::shared_ptr<TaskPool> taskPool = std::make_shared<TaskPool>();
148 std::packaged_task<TaskPool::BindedTask> bindedTask(testTask);
|