使用Node-API接口从异步线程向ArkTS线程投递指定优先级和入队方式的任务

函数说明

napi_status napi_call_threadsafe_function_with_priority(napi_threadsafe_function func, void *data,
                                                        napi_task_priority priority, bool isTail);

场景介绍

异步线程向ArkTS主线程中投递的任务需要根据任务指定的优先级和入队方式进行处理。

调用异步的ArkTS接口示例

示例代码

• 功能实现

  收起

  自动换行

  深色代码主题

  复制

  #include "napi/native_api.h"
  // ...
  #include <hilog/log.h>
  // ...
  static constexpr int INT_ARG_2 = 2; // 入参索引
  static constexpr int INT_ARG_12 = 12; // 入参索引
  static constexpr int INT_ARG_15 = 15; // 入参索引
  // ...
  struct CallbackData {
      napi_threadsafe_function tsfn;
      napi_async_work work;
  };
  static void CallJs(napi_env env, napi_value jsCb, void *context, void *data)
  {
      if (env == nullptr) {
          return;
      }
  
      napi_handle_scope scope = nullptr;
      napi_status status = napi_open_handle_scope(env, &scope);
      if (status != napi_ok) {
          return;
      }
  
      napi_value resultNumber = nullptr;
      napi_value undefined = nullptr;
      napi_get_undefined(env, &undefined);
      napi_value number1 = nullptr;
      napi_create_int32(env, INT_ARG_12, &number1);
      napi_value number2 = nullptr;
      napi_create_int32(env, INT_ARG_15, &number2);
      napi_value argv[2] = {number1, number2};
      napi_call_function(env, undefined, jsCb, INT_ARG_2, argv, &resultNumber);
      int32_t res = 0;
      // 获取resultNumber对应的int32值
      napi_get_value_int32(env, resultNumber, &res);
  
      napi_close_handle_scope(env, scope);
  }
  
  // 异步线程中调用该接口向ArkTS线程投递指定优先级和入队方式的任务
  static void ExecuteWork(napi_env env, void *data)
  {
      CallbackData *callbackData = reinterpret_cast<CallbackData *>(data);
      // 投递指定优先级为napi_priority_idle，入队方式为队列尾部入队的任务
      napi_call_threadsafe_function_with_priority(callbackData->tsfn, nullptr, napi_priority_idle, true);
      // 投递指定优先级为napi_priority_low，入队方式为队列尾部入队的任务
      napi_call_threadsafe_function_with_priority(callbackData->tsfn, nullptr, napi_priority_low, true);
      // 投递指定优先级为napi_priority_high，入队方式为队列尾部入队的任务
      napi_call_threadsafe_function_with_priority(callbackData->tsfn, nullptr, napi_priority_high, true);
      // 投递指定优先级为napi_priority_immediate，入队方式为队列尾部入队的任务
      napi_call_threadsafe_function_with_priority(callbackData->tsfn, nullptr, napi_priority_immediate, true);
      // 投递指定优先级为napi_priority_high，入队方式为队列头部入队的任务
      napi_call_threadsafe_function_with_priority(callbackData->tsfn, nullptr, napi_priority_high, false);
  }
  
  static void WorkComplete(napi_env env, napi_status status, void *data)
  {
      CallbackData *callbackData = reinterpret_cast<CallbackData *>(data);
      if (callbackData->tsfn != nullptr) {
          napi_release_threadsafe_function(callbackData->tsfn, napi_tsfn_release);
          callbackData->tsfn = nullptr;
      }
      if (callbackData->work != nullptr) {
          napi_delete_async_work(env, callbackData->work);
          callbackData->work = nullptr;
      }
      delete callbackData;
  }
  
  static napi_value CallThreadSafeWithPriority(napi_env env, napi_callback_info info)
  {
      size_t argc = 1;
      napi_value jsCb = nullptr;
      CallbackData *callbackData = new CallbackData();
      napi_get_cb_info(env, info, &argc, &jsCb, nullptr, nullptr);
      napi_value resourceName = nullptr;
      napi_create_string_utf8(env, "Thread-safe Function Demo", NAPI_AUTO_LENGTH, &resourceName);
      if (napi_create_threadsafe_function(env, jsCb, nullptr, resourceName, 0, 1, nullptr, nullptr, nullptr, CallJs,
                                          &callbackData->tsfn) != napi_ok) {
          delete callbackData;
          return nullptr;
      }
      // 创建一个异步任务对象
      if (napi_create_async_work(env, nullptr, resourceName,
                                 ExecuteWork, WorkComplete, callbackData, &callbackData->work) != napi_ok) {
          if (callbackData->tsfn != nullptr) {
              napi_release_threadsafe_function(callbackData->tsfn, napi_tsfn_release);
          }
          delete callbackData;
          return nullptr;
      }
      if (napi_queue_async_work(env, callbackData->work) != napi_ok) {
          if (callbackData->tsfn != nullptr) {
              napi_release_threadsafe_function(callbackData->tsfn, napi_tsfn_release);
          }
          napi_delete_async_work(env, callbackData->work);
          delete callbackData;
          return nullptr;
      }
      return nullptr;
  }

  napi_init.cpp

• 模块注册

  收起

  自动换行

  深色代码主题

  复制

  // 注册模块接口
  EXTERN_C_START
  static napi_value Init(napi_env env, napi_value exports)
  {
      napi_property_descriptor desc[] = {
          { "callThreadSafeWithPriority", nullptr, CallThreadSafeWithPriority, 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 callThreadSafeWithPriority: (cb: (a: number, b: number) => number) => void;

  Index.d.ts

• 编译配置

  CMakeLists.txt文件需要按照如下配置

  收起

  自动换行

  深色代码主题

  复制

  # the minimum version of CMake.
  cmake_minimum_required(VERSION 3.5.0)
  project(MyApplication3)
  
  set(NATIVERENDER_ROOT_PATH ${CMAKE_CURRENT_SOURCE_DIR})
  
  if(DEFINED PACKAGE_FIND_FILE)
      include(${PACKAGE_FIND_FILE})
  endif()
  add_definitions( "-DLOG_TAG=\"LOG_TAG\"" )
  include_directories(${NATIVERENDER_ROOT_PATH}
                      ${NATIVERENDER_ROOT_PATH}/include)
  
  add_library(entry SHARED napi_init.cpp)
  target_link_libraries(entry PUBLIC libace_napi.z.so libhilog_ndk.z.so)

• ArkTS导入头文件

  收起

  自动换行

  深色代码主题

  复制

  import testNapi from 'libentry.so';

• ArkTS代码示例

  收起

  自动换行

  深色代码主题

  复制

  // index.ets
  let callback = (a: number, b: number): number => {
    console.info('result is ' + (a + b))
    return a + b;
  }
  testNapi.callThreadSafeWithPriority(callback);

  Index.ets