HarmonyOS 鸿蒙Next Native如何在异步线程里安全回调到ArkTs线程中

可以通过以下方法在异步线程中安全回调到ArkTS线程：

1.使用napi_call_threadsafe_function_with_priority：

可以使用Node-API中的napi_call_threadsafe_function_with_priority接口从异步线程向ArkTS线程投递任务 。该接口允许指定任务的优先级和入队方式。

参考示例：https://developer.huawei.com/consumer/cn/doc/harmonyos-guides-V5/use-call-threadsafe-function-with-priority-V5

2.使用libuv异步库：

在C++层建立的子线程中，通过调用libuv接口（如uv_queue_work）抛ArkTS任务到loop中执行。

3.在非ArkTS线程中回调ArkTS接口：

通过napi_get_uv_event_loop获取env对应的loop，并抛任务到ArkTS线程 。

我们这边没有so可以调用，外部so引入参考链接：

https://gitee.com/openharmony-sig/tpc_c_cplusplus/blob/master/lycium/doc/app_calls_third_lib.md

以下是异步线程调用参考代码

struct ArkCallNativeData {

  napi_async_work asyn_work = nullptr;

  napi_ref callbackRef = nullptr; // 延长函数的生命周期

  double a = 0;

  double b = 0;

  double result = 0;

};

static void AysncExcuteCB(napi_env env, void *data) {

  OH_LOG_Print(LOG_APP, LOG_INFO, LOG_PRINT_DOMAIN, "ArkCallNative", "AysncExcuteCB>>>>>>>>>>>>>>>");

  ArkCallNativeData *callBack = reinterpret_cast<ArkCallNativeData *>(data);

  callBack->result = callBack->a + callBack->b;

  //此处10s 模拟耗时任务，可在这里调用你的耗时so任务

  std::this_thread::sleep_for(std::chrono::seconds(10));

}

static void AsyncCompeleCB(napi_env env, napi_status status, void *data) {

  ArkCallNativeData *callBackData = reinterpret_cast<ArkCallNativeData *>(data);

  napi_value callBackArg[1] = {nullptr};

  // 创建返回参数

  napi_create_double(env, callBackData->result, &callBackArg[0]);

  // 获取回调函数

  napi_value callback = nullptr;

  // 获取回调函数保存的引用

  napi_get_reference_value(env, callBackData->callbackRef, &callback);

  // 执行回调函数

  napi_value result;

  napi_value undefined;

  napi_get_undefined(env, &undefined);

  //此处回调您的so结果

  napi_call_function(env, undefined, callback, 1, callBackArg, &result);

  // 删除异步任务和回调

  napi_delete_reference(env, callBackData->callbackRef);

  napi_delete_async_work(env, callBackData->asyn_work);

  OH_LOG_Print(LOG_APP, LOG_INFO, LOG_PRINT_DOMAIN, "ArkCallNative", "AsyncCompeleCB>>>>>>>>>>>>>>>");

  delete callBackData;

}

/**

  * 异步调用

  * @param env

  * @param info

  * @return

  */

static napi_value ArkAsyncCallNatvieFunc(napi_env env, napi_callback_info info) {

  size_t argc = 3;

  napi_value args[3] = {nullptr};

  // 获取参数

  napi_get_cb_info(env, info, &argc, args, nullptr, nullptr);

  auto asynContext = new ArkCallNativeData();

  // 保存参数到CallBack

  double args1 = 0;

  napi_get_value_double(env, args[0], &asynContext->a);

  napi_get_value_double(env, args[1], &asynContext->b);

  // 保存函数引用 将传入的cb函数 转换为napi_ref 延长生命周期 ====Mark

  napi_create_reference(env, args[2], 1, &asynContext->callbackRef);

  napi_value resourceName;

  napi_create_string_utf8(env, "ArkAsyncCallNatvieFunc", NAPI_AUTO_LENGTH, &resourceName);

  // 创建异步线程函数

  napi_create_async_work(env, nullptr, resourceName, AysncExcuteCB, AsyncCompeleCB, asynContext,

    &asynContext->asyn_work);

  // 加入队列

  napi_queue_async_work(env, asynContext->asyn_work);

  return nullptr;

}

arkts侧函数声明

export const arkAsyncCallNatvieFunc: (a: number, b: number, cb: (res: number) => void) => void