HarmonyOS鸿蒙Next中如何在Native侧C++子线程直接调用ArkTS接口，不用通过ArkTS侧触发回调

楼主好，我来啦哈哈，加不加分不重要，主要我喜欢话痨。

Node-API提供的napi_create_threadsafe_function他这个允许在子线程中安全调用ArkTS函数。内部通过任务队列管理调用顺序，可以保证主线程按序执行回调。然后子线程通过napi_call_threadsafe_function投递任务，主线程异步处理。要注意napi_env仅在主线程有效，子线程需通过线程安全函数绕开直接操作napi_value的限制。这样无需ArkTS主动触发Native方法，通过模块初始化时注册回调实现主动调用。

废话不多直接上步骤：

ArkTS侧注册回调函数

// index.ets

import testNapi from 'libentry.so';

@Entry

@Component

struct Index {

  @State message: string = "Hello World";

  onPageShow() {

    // 注册回调函数供Native调用

    testNapi.registerCallback((msg: string) => {

      this.message = msg; // 更新UI

    });

  }

  build() { /* UI布局 */ }

}

Native侧创建线程安全函数

// 定义线程安全函数结构体

struct ThreadSafeInfo {

  napi_threadsafe_function tsfn;

  std::string message;

};

// 创建线程安全函数

napi_value RegisterCallback(napi_env env, napi_callback_info info) {

  //  获取ArkTS传递的回调函数

  size_t argc = 1;

  napi_value args;

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

  // 创建线程安全函数

  napi_threadsafe_function tsfn;

  napi_create_threadsafe_function(

    env, args, nullptr, nullptr,

    0, 1, nullptr, nullptr, nullptr,

    [](napi_env env, napi_value js_cb, void* context, void* data) {

      // 主线程执行回调

      ThreadSafeInfo* info = static_cast<ThreadSafeInfo*>(data);

      napi_value argv;

      napi_create_string_utf8(env, info->message.c_str(), info->message.size(), &argv);

      napi_call_function(env, nullptr, js_cb, 1, &argv, nullptr);

      delete info;

    }, &tsfn

  );

  // 存储tsfn供子线程使用

  ThreadSafeInfo* threadInfo = new ThreadSafeInfo{tsfn};

  napi_wrap(env, args, threadInfo, [](napi_env, void* data, void*) {

    napi_release_threadsafe_function(static_cast<ThreadSafeInfo*>(data)->tsfn, napi_tsfn_release);

    delete static_cast<ThreadSafeInfo*>(data);

  }, nullptr, nullptr);

  return nullptr;

}

子线程触发回调

// WebSocket消息接收线程

void OnMessageCallback(const char* msg) {

  // 构造消息数据

  ThreadSafeInfo* info = new ThreadSafeInfo;

  info->message = std::string(msg);

  // 向主线程投递任务

  napi_call_threadsafe_function(info->tsfn, info, napi_tsfn_blocking);

}