diff --git a/bundle.json b/bundle.json index 555edf474c2256dbd1d23bce3fbd76d8a05b1d29..7633d1959adbfbf7020452a093b1d531e2888295 100644 --- a/bundle.json +++ b/bundle.json @@ -57,7 +57,8 @@ "power_manager", "openssl", "ffmpeg", - "zlib" + "zlib", + "ffrt" ] }, "build": { diff --git a/services/distributedhardwarefwkservice/BUILD.gn b/services/distributedhardwarefwkservice/BUILD.gn index a3d7134e402eb35f1dd84c30b722f9dd3566c6e8..45aca4789ea52d39af48e41b39a7da835c41fd65 100644 --- a/services/distributedhardwarefwkservice/BUILD.gn +++ b/services/distributedhardwarefwkservice/BUILD.gn @@ -137,6 +137,7 @@ ohos_shared_library("distributedhardwarefwksvr") { "device_manager:devicemanagersdk", "dsoftbus:softbus_client", "eventhandler:libeventhandler", + "ffrt:libffrt", "hilog:libhilog", "hisysevent:libhisysevent", "hitrace:hitrace_meter", diff --git a/services/distributedhardwarefwkservice/src/componentmanager/component_manager.cpp b/services/distributedhardwarefwkservice/src/componentmanager/component_manager.cpp index e40358f86486326e6529e1ae05c31a05948339ca..a3c25b8fbd84bd32a31281b58fbfb0877066be34 100644 --- a/services/distributedhardwarefwkservice/src/componentmanager/component_manager.cpp +++ b/services/distributedhardwarefwkservice/src/componentmanager/component_manager.cpp @@ -21,6 +21,7 @@ #include #include +#include "ffrt.h" #include "ipc_object_stub.h" #include "iservice_registry.h" #include "system_ability_definition.h" @@ -903,7 +904,7 @@ void ComponentManager::DumpLoadedComps(std::set &compSourceType, std::se void ComponentManager::Recover(DHType dhType) { - std::thread([this, dhType]() { this->DoRecover(dhType); }).detach(); + ffrt::submit([this, dhType]() { this->DoRecover(dhType); }); } void ComponentManager::DoRecover(DHType dhType) diff --git a/services/distributedhardwarefwkservice/src/distributed_hardware_manager_factory.cpp b/services/distributedhardwarefwkservice/src/distributed_hardware_manager_factory.cpp index 45f651f122800b82ed78ecf7eedc5d299e1bb7d5..61ff97dbaa12f23a883cfbb25485e177dd7a3736 100644 --- a/services/distributedhardwarefwkservice/src/distributed_hardware_manager_factory.cpp +++ b/services/distributedhardwarefwkservice/src/distributed_hardware_manager_factory.cpp @@ -22,6 +22,7 @@ #include #include +#include "ffrt.h" #include "iservice_registry.h" #include "system_ability_definition.h" @@ -138,9 +139,9 @@ void DistributedHardwareManagerFactory::CheckExitSAOrNot() GetAnonyString(networkId).c_str(), GetAnonyString(uuid).c_str()); uint16_t deviceType = deviceInfo.deviceTypeId; - std::thread([this, networkId, uuid, udid, deviceType]() { + ffrt::submit([this, networkId, uuid, udid, deviceType]() { this->SendOnLineEvent(networkId, uuid, udid, deviceType); - }).detach(); + }); } } diff --git a/services/distributedhardwarefwkservice/src/task/disable_task.cpp b/services/distributedhardwarefwkservice/src/task/disable_task.cpp index 6fbff36e5b9b58c0c70c96b737691fbce5a8f9ae..80d1e13547472dbfd0a02991909835981f4ec580 100644 --- a/services/distributedhardwarefwkservice/src/task/disable_task.cpp +++ b/services/distributedhardwarefwkservice/src/task/disable_task.cpp @@ -17,6 +17,8 @@ #include +#include "ffrt.h" + #include "anonymous_string.h" #include "capability_utils.h" #include "component_manager.h" @@ -49,7 +51,7 @@ DisableTask::~DisableTask() void DisableTask::DoTask() { - std::thread([this]() { this->DoTaskInner(); }).detach(); + ffrt::submit([this]() { this->DoTaskInner(); }); } void DisableTask::DoTaskInner() diff --git a/services/distributedhardwarefwkservice/src/task/enable_task.cpp b/services/distributedhardwarefwkservice/src/task/enable_task.cpp index daf0a9bf2e67e2682a9b9b9fd7319d44bee67605..1287e69f9fce679aab42c4d8cc081d9060436cc2 100644 --- a/services/distributedhardwarefwkservice/src/task/enable_task.cpp +++ b/services/distributedhardwarefwkservice/src/task/enable_task.cpp @@ -17,6 +17,8 @@ #include +#include "ffrt.h" + #include "anonymous_string.h" #include "capability_utils.h" #include "component_manager.h" @@ -48,7 +50,7 @@ EnableTask::~EnableTask() void EnableTask::DoTask() { - std::thread([this]() { this->DoTaskInner(); }).detach(); + ffrt::submit([this]() { this->DoTaskInner(); }); } void EnableTask::DoTaskInner() diff --git a/services/distributedhardwarefwkservice/src/task/offline_task.cpp b/services/distributedhardwarefwkservice/src/task/offline_task.cpp index a352acb102cde44b4a0993d888297b2f8dbad701..d77b14d16dafe736df39fa89e7e832372e71a39d 100644 --- a/services/distributedhardwarefwkservice/src/task/offline_task.cpp +++ b/services/distributedhardwarefwkservice/src/task/offline_task.cpp @@ -18,6 +18,8 @@ #include #include +#include "ffrt.h" + #include "anonymous_string.h" #include "capability_info_manager.h" #include "constants.h" @@ -54,7 +56,7 @@ OffLineTask::~OffLineTask() void OffLineTask::DoTask() { - std::thread([this]() { this->DoTaskInner(); }).detach(); + ffrt::submit([this]() { this->DoTaskInner(); }); } void OffLineTask::DoTaskInner() diff --git a/services/distributedhardwarefwkservice/src/task/task_executor.cpp b/services/distributedhardwarefwkservice/src/task/task_executor.cpp index 262cab78004b3d2c6055454720fcdff1455840af..37b6b898bf22146757d0a96415df8c190150702e 100644 --- a/services/distributedhardwarefwkservice/src/task/task_executor.cpp +++ b/services/distributedhardwarefwkservice/src/task/task_executor.cpp @@ -18,6 +18,8 @@ #include #include +#include "ffrt.h" + #include "constants.h" #include "dh_context.h" #include "distributed_hardware_errno.h" @@ -32,7 +34,7 @@ IMPLEMENT_SINGLE_INSTANCE(TaskExecutor); TaskExecutor::TaskExecutor() : taskThreadFlag_(true) { DHLOGI("Ctor TaskExecutor"); - std::thread([this]() { this->TriggerTask(); }).detach(); + ffrt::submit([this]() { this->TriggerTask(); }); } TaskExecutor::~TaskExecutor() diff --git a/services/distributedhardwarefwkservice/test/unittest/common/accessmanager/BUILD.gn b/services/distributedhardwarefwkservice/test/unittest/common/accessmanager/BUILD.gn index 4935935f685005a9e1aa65153f0307380b84602d..e7de7bb01187584a10eb377217b033e2805baa81 100644 --- a/services/distributedhardwarefwkservice/test/unittest/common/accessmanager/BUILD.gn +++ b/services/distributedhardwarefwkservice/test/unittest/common/accessmanager/BUILD.gn @@ -34,12 +34,7 @@ config("module_private_config") { ohos_unittest("AccessManagerTest") { module_out_path = module_out_path - sources = [ - "${services_path}/distributedhardwarefwkservice/src/accessmanager/access_manager.cpp", - "${services_path}/distributedhardwarefwkservice/src/distributed_hardware_manager_factory.cpp", - ] - - sources += [ "access_manager_test.cpp" ] + sources = [ "access_manager_test.cpp" ] configs = [ ":module_private_config" ] diff --git a/utils/src/histreamer_query_tool.cpp b/utils/src/histreamer_query_tool.cpp index 86a6ff5d9d22f9dfd39d4a6c07939fd7a728314b..1815edf65bfa7e66593b410073677ea10d8178ec 100644 --- a/utils/src/histreamer_query_tool.cpp +++ b/utils/src/histreamer_query_tool.cpp @@ -16,7 +16,7 @@ #include "histreamer_query_tool.h" #include -#include +#include #include "distributed_hardware_log.h"