如何使用napi_call_threadsafe_function_with_priority接口投递任务（包括参数设置等）？

Question

如题：如何使用napi_call_threadsafe_function_with_priority接口投递任务（包括参数设置等）？

本文参与了 【 HarmonyOS NEXT 技术问答冲榜，等你来战！】欢迎正在阅读的你也加入。

Answer 1

在C++代码中，首先创建CallbackData结构体实例，用于存储相关数据（如线程安全函数对象tsfn和异步工作对象work）。然后通过napi_create_threadsafe_function创建线程安全函数，并在CallJs回调函数中定义ArkTS线程接收到任务后的处理逻辑（如调用传入的JavaScript回调函数并传递参数）。接着创建异步工作对象（napi_create_async_work），并在ExecuteWork函数中使用napi_call_threadsafe_function_with_priority投递任务，设置任务的优先级（如napi_priority_idle、napi_priority_low、napi_priority_high、napi_priority_immediate等）和入队方式（true表示从队列尾部入队，false表示从队列头部入队）。最后将异步工作对象加入队列（napi_queue_async_work）。示例代码如下：

struct CallbackData {
    napi_threadsafe_function tsfn;
    napi_async_work work;
};

// 异步线程中调用该接口向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);
    //... 其他任务投递
}

static napi_value CallThreadSafeWithPriority(napi_env env, napi_callback_info info) {
    size_t argc = 1;
    napi_value jsCb = nullptr;
    CallbackData *callbackData = nullptr;
    napi_get_cb_info(env, info, &argc, &jsCb, nullptr, reinterpret_cast<void **>(&callbackData));
    napi_value resourceName = nullptr;
    napi_create_string_utf8(env, "Thread-safe Function Demo", NAPI_AUTO_LENGTH, &resourceName);
    napi_create_threadsafe_function(env, jsCb, nullptr, resourceName, 0, 1, callbackData, nullptr, callbackData, CallJs,
                                    &callbackData->tsfn);
    napi_create_async_work(env, nullptr, resourceName, ExecuteWork, WorkComplete, callbackData, &callbackData->work);
    napi_queue_async_work(env, callbackData->work);
    return nullptr;
}

本文参与了 【 HarmonyOS NEXT 技术问答冲榜，等你来战！】欢迎正在阅读的你也加入。