0
  • 聊天消息
  • 系统消息
  • 评论与回复
登录后你可以
  • 下载海量资料
  • 学习在线课程
  • 观看技术视频
  • 写文章/发帖/加入社区
会员中心
创作中心

完善资料让更多小伙伴认识你,还能领取20积分哦,立即完善>

3天内不再提示

ArkUI 中的线程和看门狗机制

王程 来源: jf_75796907 作者: jf_75796907 2024-02-18 17:37 次阅读

一、前言

本文主要分析 ArkUI 中涉及的线程和看门狗机制。

二、ArkUI 中的线程

应用 Ability 首次创建界面的流程大致如下:

wKgaomXRz-KAOIl7AAAUX4GNkUw147.png

说明:

AceContainer 是一个容器类,由前端、任务执行器、资源管理器、渲染管线、视图等聚合而成,提供了生命周期对接、功能调度接口和 UI 渲染的各项能力。

・Ability 在 FA 模型中实际为 AceAbility,和 AceContainer 容器类搭配管理界面。在 AceAbility 的生命周期函数 AceAbility::OnStart (const Want& want) 中创建 AceContainer 实例。

・对于 Stage 模型,在 UIContentImpl::CommonInitialize () 函数中创建 AceContainer 实例。AceContainer 在构造函数中创建任务执行器,用于执行 ArkUI 相关任务。

void AceContainer::InitializeTask()
{
 auto flutterTaskExecutor = Referenced::MakeRefPtr< FlutterTaskExecutor >();
 flutterTaskExecutor->InitPlatformThread(useCurrentEventRunner_);
 taskExecutor_ = flutterTaskExecutor;
 // No need to create JS Thread for DECLARATIVE_JS
 if (type_ == FrontendType::DECLARATIVE_JS) {
 GetSettings().useUIAsJSThread = true;
 } else {
 flutterTaskExecutor->InitJsThread();
 }
}

任务有如下几种类型,每种类型 (BACKGROUND 任务除外) 的任务会由一个 fml::TaskRunner 去执行。TaskRunner 代码在三方库 third_partyflutterenginefluttercommontask_runners.h 中,实现原理和 EventRunner,EventHandler 机制相似。

 enum class TaskType : uint32_t {
 PLATFORM = 0,
 UI,
 IO,
 GPU,
 JS,
 BACKGROUND,
 UNKNOWN,
 };

FlutterTaskExecutor 类图如下:

wKgZomXRz-OAS5hGAAAx8gzJp7U465.png

说明:

・任务执行器可以用于执行异步 (PostTask) 和同步 (PostSyncTask) 任务。

・异步任务:把任务丢给指定类型的线程处理,不会阻塞当前线程。

・同步任务:把任务丢给指定类型的线程处理并阻塞当前线程,直到任务执行完后继续当前线程。

・比如触摸事件的处理,会以异步任务的形式被丢到 UI 线程中处理。

 auto&& touchEventCallback = [context = pipelineContext_, id = instanceId_](
 const TouchEvent& event, const std::function< void() >& markProcess) {
 ContainerScope scope(id);
 context->GetTaskExecutor()->PostTask(
 [context, event, markProcess]() {
 context->OnTouchEvent(event);
 CHECK_NULL_VOID_NOLOG(markProcess);
 markProcess();
 },
 TaskExecutor::TaskType::UI);
 };

三、各种类型的 TaskRunner 如何初始化?

platformRunner_

在 InitPlatformThread 函数中初始化。

void FlutterTaskExecutor::InitPlatformThread(bool useCurrentEventRunner)
{
#ifdef OHOS_STANDARD_SYSTEM
 platformRunner_ = flutter::PlatformTaskRunner::CurrentTaskRunner(useCurrentEventRunner);
#else
 fml::MessageLoop::EnsureInitializedForCurrentThread();
 platformRunner_ = fml::MessageLoop::GetCurrent().GetTaskRunner();
#endif

 FillTaskTypeTable(TaskType::PLATFORM);
}

对于标准 OHOS,platformRunner_实际为

flutter::PlatformTaskRunner::CurrentTaskRunner(useCurrentEventRunner)

看下具体实现:

fml::RefPtr< fml::TaskRunner > PlatformTaskRunner::CurrentTaskRunner(bool useCurrentEventRunner)
{
 return PlatformTaskRunnerAdapter::CurrentTaskRunner(useCurrentEventRunner);
}
fml::RefPtr< fml::TaskRunner > PlatformTaskRunnerAdapter::CurrentTaskRunner(bool useCurrentEventRunner)
{
 if (useCurrentEventRunner) {
 return fml::MakeRefCounted< PlatformTaskRunnerAdapter >(useCurrentEventRunner);
 }
 if (taskRunner_) {
 return taskRunner_;
 }
 taskRunner_ = fml::MakeRefCounted< PlatformTaskRunnerAdapter >(useCurrentEventRunner);
 return taskRunner_;
}

说明:

platformRunner 实际类型为 PlatformTaskRunnerAdapter。

PlatformTaskRunnerAdapter 继承自 fml::TaskRunner,实现了 virtual void PostTask (fml::closure task) 等接口函数。实际是在 EventRunner,EventHandler 机制基础上又做了层封装。代码中 useCurrentEventRunner 实参为 false。意味着 platformRunner 实际是把任务丢给主线程去做的。(MainEventRunner 对应的线程为主线程,MainEventRunner 的初始化在 Ability 框架 MainThread::Start () 函数中)

PlatformTaskRunnerAdapter::PlatformTaskRunnerAdapter(bool useCurrentEventRunner)
 : fml::TaskRunner(nullptr)
{
 if (useCurrentEventRunner) {
 eventRunner_ = OHOS::AppExecFwk::EventRunner::Current();
 } else {
 eventRunner_ = OHOS::AppExecFwk::EventRunner::GetMainEventRunner();
 }
 eventHandler_ = std::make_shared< OHOS::AppExecFwk::EventHandler >(eventRunner_);
}

void PlatformTaskRunnerAdapter::PostTask(fml::closure task)
{
 eventHandler_->PostTask(std::move(task));
}
 

uiRunner, ioRunner, gpuRunner_

这三种类型的 TaskRunner 初始化都在 FlutterTaskExecutor::InitOtherThreads 函数中。

void FlutterTaskExecutor::InitOtherThreads(const flutter::TaskRunners& taskRunners)
{
 uiRunner_ = taskRunners.GetUITaskRunner();
 ioRunner_ = taskRunners.GetIOTaskRunner();
#ifdef NG_BUILD
 gpuRunner_ = taskRunners.GetRasterTaskRunner();
#else
 gpuRunner_ = taskRunners.GetGPUTaskRunner();
#endif

 //...此处省略若干行
}

FlutterTaskExecutor::InitOtherThreads 函数的参数 taskRunners 从哪来?

FlutterAceView::CreateView () 函数中会初始化一些配置项,然后创建 flutter::OhosShellHolder 对象。

FlutterAceView* FlutterAceView::CreateView(int32_t instanceId, bool useCurrentEventRunner, bool usePlatformThread)
{
 FlutterAceView* aceSurface = new Platform::FlutterAceView(instanceId);
 if (aceSurface != nullptr) {
 aceSurface->IncRefCount();
 }
 flutter::Settings settings;
 settings.instanceId = instanceId;
 settings.platform = flutter::AcePlatform::ACE_PLATFORM_OHOS;
#ifndef GPU_DISABLED
 settings.enable_software_rendering = false;
#else
 settings.enable_software_rendering = true;
#endif
#ifdef ENABLE_ROSEN_BACKEND
 settings.use_system_render_thread = SystemProperties::GetRosenBackendEnabled();
#endif
 settings.platform_as_ui_thread = usePlatformThread;
 settings.use_current_event_runner = useCurrentEventRunner;
 // ...此处省略若干行
 auto shell_holder = std::make_unique< flutter::OhosShellHolder >(settings, false);
 if (aceSurface != nullptr) {
 aceSurface->SetShellHolder(std::move(shell_holder));
 }
 return aceSurface;
}

OhosShellHolder 构造函数中会根据传入的参数创建 flutter::TaskRunners。

OhosShellHolder::OhosShellHolder(
 flutter::Settings settings,
 bool is_background_view)
 : settings_(std::move(settings))
{
 // ...此处省略若干行
 // The current thread will be used as the platform thread. Ensure that the
 // message loop is initialized.
 fml::MessageLoop::EnsureInitializedForCurrentThread();
 fml::RefPtr< fml::TaskRunner > gpu_runner;
 fml::RefPtr< fml::TaskRunner > ui_runner;
 fml::RefPtr< fml::TaskRunner > io_runner;
 fml::RefPtr< fml::TaskRunner > platform_runner =
 PlatformTaskRunnerAdapter::CurrentTaskRunner(settings_.use_current_event_runner);
 if (is_background_view) {
 auto single_task_runner = thread_host_.ui_thread->GetTaskRunner();
 gpu_runner = single_task_runner;
 ui_runner = single_task_runner;
 io_runner = single_task_runner;
 } else {
 if (settings_.platform_as_ui_thread) {
 ui_runner = platform_runner;
 } else {
 ui_runner = thread_host_.ui_thread->GetTaskRunner();
 }
 if (!settings_.use_system_render_thread) {
 gpu_runner = thread_host_.gpu_thread->GetTaskRunner();
 } else {
 gpu_runner = ui_runner;
 }
 if (settings_.use_io_thread) {
 io_runner = thread_host_.io_thread->GetTaskRunner();
 } else {
 io_runner = ui_runner;
 }
 }
 flutter::TaskRunners task_runners(thread_label, // label
 platform_runner, // platform
 gpu_runner, // gpu
 ui_runner, // ui
 io_runner // io
 );
 

说明:目前 OHOS 上,配置的参数如下:

wKgaomXRz-OAYohbAAB5eS149Wk451.png

对照上面的代码段,实际 gpu_runner,ui_runner,io_runner 是同一个,任务都在 UI 线程执行。另外对于 Stage 模型,ui_runner 和 platform_runner 又是同一个,所以对 Stage 模型来说,TaskType::UI,TaskType::IO,TaskType::GPU,TaskType::PLATFORM 类型的任务实际都是由主线程来执行的。

jsRunner_

初始化在 FlutterTaskExecutor::InitJsThread (bool newThread) 函数中。

void FlutterTaskExecutor::InitJsThread(bool newThread)
{
 if (newThread) {
 jsThread_ = std::make_unique< fml::Thread >(GenJsThreadName());
 jsRunner_ = jsThread_->GetTaskRunner();
 } else {
 jsRunner_ = uiRunner_;
 }

 PostTaskToTaskRunner(
 jsRunner_, [weak = AceType::WeakClaim(this)] { FillTaskTypeTable(weak, TaskType::JS); }, 0);
}

说明:对于声明式前端,newThread 参数为 false; JS 前端为 true。所以声明式前端 JS 线程实际为 UI 线程;而对于 JS 前端,会起独立的 JS 线程来处理 JS 相关的任务。

TaskType::BACKGROUND 类型的任务如何执行?

TaskType::BACKGROUND 类型的任务会由单例 BackgroundTaskExecutor 去执行。BackgroundTaskExecutor 中维护了一个 8 个线程的线程池,用来处理后台耗时操作。线程名以 “ace.bg.” 开头。比如 RosenFontLoader 在加载网络字体的时候,下载操作会放到后台任务线程里去做。

void RosenFontLoader::LoadFromNetwork(const OHOS::Ace::RefPtr< OHOS::Ace::PipelineBase >& context)
{
 auto weakContext = AceType::WeakClaim(AceType::RawPtr(context));
 context->GetTaskExecutor()->PostTask(
 [weak = AceType::WeakClaim(this), weakContext] {
 auto fontLoader = weak.Upgrade();
 auto context = weakContext.Upgrade();
 if (!fontLoader || !context) {
 return;
 }
 std::vector< uint8_t > fontData;
 if (!DownloadManager::GetInstance().Download(fontLoader->familySrc_, fontData) || fontData.empty()) {
 return;
 }
 //...此处省略若干行
 },
 TaskExecutor::TaskType::BACKGROUND);
}

综上:在 ArkUI 中,会为每个带界面的 Ability 创建一个 AceContainer, 每个 AceContainer 中会创建一个 FlutterTaskExecutor 用于处理该 Ability ArkUI 相关的任务。根据不同的模型,ArkUI 创建出来的线程会有所不同:

・对于 Stage 模型的应用,ui 线程复用了主线程,并且 Stage 模型应用目前都是声明式前端,导致 js 线程又复用了 ui 线程。所以 ArkUI 只需另外创建名字以 “ace.bg.” 开头的八个后台任务线程。

・对于 FA 模型的应用,除了八个后台任务线程,根据 Ability 的数量会创建若干个名字以 “.ui” 结尾的线程。如果是 JS 前端,还会创建若干个名字以 “jsThread-” 开头的线程。

四、ArkUI 中的看门狗

wKgZomXRz-SACe6XAABWAdOVFOk676.png

AceEngine 是单例,全局唯一。AceEngine 的构造函数中会创建 WatchDog 实例。对于 FA 模型的应用,AceContainer::AttachView () 函数中通过调用

AceEngine::Get().RegisterToWatchDog(instanceId, taskExecutor_,

GetSettings().useUIAsJSThread);

把持有的 FlutterTaskExecutor 注册到看门狗中看护。

看门狗只看护 FlutterTaskExecutor 中的 UI 线程和 JS 线程。Stage 模型的应用由于 UI 线程和 JS 线程实际是复用的主线程,所以不需要在 ArkUI 中看护。Ability 框架中有看门狗专门看护主线程。如果线程中有任务处理超过了 3s,会上报 RawEventType::WARNING 对应的系统事件给 hiview 插件平台;如果任务处理超过了 5s,会上报 RawEventType::FREEZE 对应的系统事件给 hiview 插件平台,hiview 插件平台会生成 appfreeze 的 dump 文件。

为了防止主线程和 ui 线程卡住引起 appfreeze,做应用开发的时候,不要在 Ability 生命周期函数或者控件点击事件等回调函数中做耗时操作。

审核编辑 黄宇

声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉
  • 看门狗
    +关注

    关注

    10

    文章

    558

    浏览量

    70691
  • 鸿蒙
    +关注

    关注

    57

    文章

    2301

    浏览量

    42663
收藏 人收藏

    评论

    相关推荐

    看门狗定时器的工作原理

    看门狗定时器是一种独立的计时器硬件模块,其核心功能是倒计时。如果系统软件在计时器超时前没有对其进行复位操作(即“喂狗”),看门狗将触发一个预定义的动作,通常是系统复位或中断。
    的头像 发表于 10-21 14:18 181次阅读
    <b class='flag-5'>看门狗</b>定时器的工作原理

    单片机开发:使用内部看门狗定时器(WDT)还是外挂看门狗芯片?

    在电子产品,有时候需要看门狗定时器(WDT),看门狗芯片有外部和内置两种。在设计之初,要不要使用看门狗芯片?这是个值得考虑的问题。在本文中,英锐恩技术工程师对内部和外部
    发表于 09-25 13:46

    Sitara AM6442 RTI看门狗调试

    电子发烧友网站提供《Sitara AM6442 RTI看门狗调试.pdf》资料免费下载
    发表于 08-27 11:26 0次下载
    Sitara AM6442 RTI<b class='flag-5'>看门狗</b>调试

    【GD32F470紫藤派开发板使用手册】第七讲 FWDG-看门狗实验

    通过本实验主要学习以下内容: 独立看门狗的原理 独立看门狗功能介绍 实现独立看门狗功能
    的头像 发表于 05-11 10:13 821次阅读
    【GD32F470紫藤派开发板使用手册】第七讲 FWDG-<b class='flag-5'>看门狗</b>实验

    【GD32H757Z海棠派开发板使用手册】第七讲 FWDG-看门狗实验

    通过本实验主要学习以下内容: 独立看门狗的原理 独立看门狗功能介绍 实现独立看门狗功能
    的头像 发表于 05-10 09:37 586次阅读
    【GD32H757Z海棠派开发板使用手册】第七讲 FWDG-<b class='flag-5'>看门狗</b>实验

    软件看门狗和硬件看门狗的区别

    软件看门狗和硬件看门狗都是用于监控系统崩溃的工具,它们的作用是在系统出现故障或异常情况时自动恢复系统。  软件看门狗是一种程序,运行在操作系统,通过定时检测系统是否正常运行来判断系统
    的头像 发表于 04-16 15:10 869次阅读

    TLF35584集成的看门狗工作应用案例

    看门狗输入引脚 WDI 具有集成的下拉电流 IWDI 。看门狗输入 WDI 可以在“Closed Window”内或随后的“Open Window”期间转换为高电平。
    发表于 03-18 11:27 3418次阅读
    TLF35584<b class='flag-5'>中</b>集成的<b class='flag-5'>看门狗</b>工作应用案例

    调试模式下如何调试看门狗

    大家在调试GD32 MCU系统的时候,若开了看门狗外设,是否会碰到进入调试模式看门狗就会咬造成无法调试的问题?
    的头像 发表于 02-23 09:30 1162次阅读
    调试模式下如何调试<b class='flag-5'>看门狗</b>?

    芯知识 | 语音芯片中的声音播放提示IC内置看门狗的作用介绍

    随着科技的不断发展,语音芯片在各个领域的应用越来越广泛。其中,声音播放提示IC作为语音芯片的重要组成部分,其功能和性能的提升对于产品的用户体验和稳定性至关重要。而在声音播放提示IC,内置看门狗
    的头像 发表于 12-20 08:40 458次阅读
    芯知识 | 语音芯片中的声音播放提示IC内置<b class='flag-5'>看门狗</b>的作用介绍

    UVM环境的看门狗怎么没看住超时了?

    uvm验证环境里一般通过objection机制来控制仿真的结束,不过在机制之外,有时还需要通过看门狗来watchdog避免仿真环境挂死,watchdog配合objection一起来控制仿真的进行与结束。
    的头像 发表于 12-04 11:42 1030次阅读

    MCU看门狗应用注意事项

    我们使用的MCU是普冉的PY32F030,这颗芯片在低功耗应用场景下,使用看门狗会有很多的问题和缺陷,需要非常注意,稍有不慎,就会出问题。
    发表于 12-02 09:47 1045次阅读
    MCU<b class='flag-5'>看门狗</b>应用注意事项

    STM32的看门狗原理和示例代码

    看门狗基础:STM32微控制器上的看门狗主要有两种类型:独立看门狗(IWDG)和窗口看门狗(WWDG),这两者都是用于监控系统运行状态的机制
    的头像 发表于 12-01 08:00 1799次阅读
    STM32的<b class='flag-5'>看门狗</b>原理和示例代码

    RT-Thread Nano入门:独立看门狗(IWDT)

    本文主要介绍怎么用RT-Thread Nano实现独立看门狗IWDT驱动,创建一个喂狗线程,实现定时喂狗功能。
    的头像 发表于 11-22 11:04 2054次阅读
    RT-Thread Nano入门:独立<b class='flag-5'>看门狗</b>(IWDT)

    什么是模拟看门狗?模拟看门狗有什么用处?

    看门狗大家应该再熟悉不过了,一旦忘记喂狗就会导致单片机复位,而在大部分stm32都存在两种类型的看门狗,Independent watchdog (IWDG)独立看门狗和Window
    的头像 发表于 11-22 09:40 1594次阅读
    什么是模拟<b class='flag-5'>看门狗</b>?模拟<b class='flag-5'>看门狗</b>有什么用处?

    看门狗要如何使用?

    虽然知道看门狗的作用,不过还是不太明白看门狗要如何使用。 看门狗的作用是在程序跑飞的情况下让系统能够及时复位重新开始执行程序,道理很简单,但是程序如何跑飞呢? 如果是一段程序需要延时等待,这个不算跑飞吧,应该是正常执行。所以这种
    发表于 11-06 07:02