鸿蒙5.0开发进阶：NDK开发-使用扩展的Node-API接口在异步线程中运行和停止事件循环

往期鸿蒙全套实战文章必看：

场景介绍

开发者在自己创建的ArkTS运行环境中调用异步的ArkTS接口时，可以通过使用Node-API中的扩展接口napi_run_event_loop和napi_stop_event_loop来运行和停止ArkTS实例中的事件循环。

调用异步的ArkTS接口示例

调用的ArkTS接口为异步接口时，需要通过扩展接口napi_run_event_loop将异步线程中的事件循环运行起来，底层事件队列中的异步任务将被处理执行。当前Node-API扩展了两种事件循环模式来运行异步线程的事件循环，分别为napi_event_mode_nowait模式和napi_event_mode_default模式。

如果使用napi_event_mode_nowait模式运行底层事件循环，系统会尝试从底层的事件队列中取出一个任务并处理，完成之后事件循环停止，如果底层的事件队列中没有任务，事件循环会立刻停止，当前的异步线程不会被阻塞；

如果使用napi_event_mode_default模式来运行底层事件循环，系统会阻塞当前的线程，同时会一直尝试从事件队列中获取任务并执行处理这些任务。如果不想当前线程继续被阻塞，可以使用扩展接口napi_stop_event_loop将正在运行的事件循环停止。

示例代码

• 模块注册

  // hello.cpp
  #include "napi/native_api.h"
  #include <napi/common.h>
  #include <pthread.h>
  
  static napi_value ResolvedCallback(napi_env env, napi_callback_info info)
  {
      napi_stop_event_loop(env);
      return nullptr;
  }
  
  static napi_value RejectedCallback(napi_env env, napi_callback_info info)
  {
      napi_stop_event_loop(env);
      return nullptr;
  }
  
  static void *RunEventLoopFunc(void *arg)
  {
      // 1. 创建ArkTS实例
      napi_env env;
      napi_status ret = napi_create_ark_runtime(&env);
      if (ret != napi_ok) {
          return nullptr;
      }
  
      // 2. 加载自定义的模块
      napi_value objectUtils;
      // 'com.example.myapplication' 为当前应用的bundleName
      ret = napi_load_module_with_info(env, "ets/pages/ObjectUtils", "com.example.myapplication/entry", &objectUtils);
      if (ret != napi_ok) {
          return nullptr;
      }
  
      // 3. 调用异步SetTimeout接口
      napi_value setTimeout = nullptr;
      napi_value promise = nullptr;
  
      napi_get_named_property(env, objectUtils, "SetTimeout", &setTimeout);
      napi_call_function(env, objectUtils, setTimeout, 0, nullptr, &promise);
  
      napi_value theFunc = nullptr;
      if (napi_get_named_property(env, promise, "then", &theFunc) != napi_ok) {
          return nullptr;
      }
  
      napi_value resolvedCallback = nullptr;
      napi_value rejectedCallback = nullptr;
      napi_create_function(env, "resolvedCallback", NAPI_AUTO_LENGTH, ResolvedCallback, nullptr, &resolvedCallback);
      napi_create_function(env, "rejectedCallback", NAPI_AUTO_LENGTH, RejectedCallback, nullptr, &rejectedCallback);
      napi_value argv[2] = {resolvedCallback, rejectedCallback};
      napi_call_function(env, promise, theFunc, 2, argv, nullptr);
  
      auto flag = reinterpret_cast<bool *>(arg);
      if (*flag == true) {
          napi_run_event_loop(env, napi_event_mode_default);
      } else {
          // 非阻塞式的处理任务，有可能队列中还没有任务就已经返回了
          napi_run_event_loop(env, napi_event_mode_nowait);
      }
      return nullptr;
  }
  
  static napi_value RunEventLoop(napi_env env, napi_callback_info info)
  {
      pthread_t tid;
      size_t argc = 1;
      napi_value argv[1] = { nullptr };
      napi_get_cb_info(env, info, &argc, argv, nullptr, nullptr);
  
      bool flag = false;
      napi_get_value_bool(env, argv[0], &flag);
      // 创建异步线程
      pthread_create(&tid, nullptr, RunEventLoopFunc, &flag);
      pthread_join(tid, nullptr);
  
      return nullptr;
  }
  
  // 注册模块接口
  EXTERN_C_START
  static napi_value Init(napi_env env, napi_value exports)
  {
      napi_property_descriptor desc[] = {
          { "runEventLoop", nullptr, RunEventLoop, nullptr, nullptr, nullptr, napi_default, nullptr }
      };
      napi_define_properties(env, exports, sizeof(desc) / sizeof(desc[0]), desc);
      return exports;
  }
  EXTERN_C_END
  
  static napi_module nativeModule = {
      .nm_version = 1,
      .nm_flags = 0,
      .nm_filename = nullptr,
      .nm_register_func = Init,
      .nm_modname = "entry",
      .nm_priv = nullptr,
      .reserved = { 0 },
  };
  
  extern "C" __attribute__((constructor)) void RegisterEntryModule()
  {
      napi_module_register(&nativeModule);
  }

• 接口声明

  // index.d.ts
  export const runEventLoop: (isDefault: boolean) => object;

• 编译配置

• ArkTS代码示例

  // index.ets
  import testNapi from 'libentry.so'
  
  testNapi.runEventLoop(true);

  // ets/pages/ObjectUtils.ets
  export function SetTimeout() : Promise<void> {
      return new Promise((resolve) => {
          setTimeout(() => {
              console.info('set timer delay 1s');
              // attempt to stop the event loop at napi terminal
              resolve();
          }, 1000)
      })
  }