1 /* 2 * Copyright (c) 2022 Huawei Device Co., Ltd. 3 * Licensed under the Apache License, Version 2.0 (the "License"); 4 * you may not use this file except in compliance with the License. 5 * You may obtain a copy of the License at 6 * 7 * http://www.apache.org/licenses/LICENSE-2.0 8 * 9 * Unless required by applicable law or agreed to in writing, software 10 * distributed under the License is distributed on an "AS IS" BASIS, 11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12 * See the License for the specific language governing permissions and 13 * limitations under the License. 14 */ 15 16 #include "task_runner.h" 17 18 #include "helper/object_helper.h" 19 20 namespace Commonlibrary::Concurrent::TaskPoolModule { 21 using namespace Commonlibrary::Concurrent::Common::Helper; TaskRunner(TaskStartCallback callback)22TaskRunner::TaskRunner(TaskStartCallback callback) : callback_(callback), selfThreadId_(uv_thread_self()) {} 23 ~TaskRunner()24TaskRunner::~TaskRunner() 25 { 26 CloseHelp::DeletePointer(taskInnerRunner_, false); 27 } 28 Run()29void TaskRunner::TaskInnerRunner::Run() 30 { 31 if (runner_ != nullptr) { 32 runner_->Run(); 33 } 34 } 35 TaskInnerRunner(const TaskRunner * runner)36TaskRunner::TaskInnerRunner::TaskInnerRunner(const TaskRunner* runner) : runner_(runner) {} 37 Run() const38void TaskRunner::Run() const 39 { 40 if (callback_.callback != nullptr) { 41 callback_.callback(callback_.data); 42 } 43 } 44 Execute()45bool TaskRunner::Execute() 46 { 47 taskInnerRunner_ = new TaskInnerRunner(this); 48 return taskInnerRunner_->Start(); 49 } 50 } // namespace Commonlibrary::Concurrent::TaskPoolModule 51