【鸿蒙开发】在 ArkTS 线程中通过 napi 创建的 C++ 线程返回处理结果

// C++线程函数void ProcessFunction(napi_env env, napi_ref callbackRef, void* data) {    // 进行耗时操作，获取处理结果    int result = 42;
    // 创建异步任务上下文    napi_handle_scope handleScope;    napi_open_handle_scope(env, &handleScope);
    napi_async_context asyncContext;    napi_create_async_context(env, nullptr, nullptr, &asyncContext);    napi_open_async_scope(env, asyncContext, &asyncScope);
    // 获取回调函数    napi_value callback;    napi_get_reference_value(env, callbackRef, &callback);        // 创建返回结果    napi_value resultValue;    napi_create_int32(env, result, &resultValue);
    // 调用回调函数，并传递结果    napi_value arguments[] = { resultValue };    napi_call_function(env, asyncContext, callback, 1, arguments, nullptr);
    // 释放资源    napi_close_async_scope(env, asyncScope);    napi_close_handle_scope(env, handleScope);}

import { napi_create_reference, napi_create_async_work, napi_queue_async_work } from '@system.napi';
function createCPlusPlusThread(env: napi_env, callback: Function, data: any) {    // 创建回调函数的引用    const callbackRef = napi_create_reference(env, callback);
    // 创建异步工作    const work = napi_create_async_work(env, null, null,        (env, data) => {            // 在C++线程中进行处理，并返回结果            ProcessFunction(env, callbackRef, data);        },        (env, status, data) => {            // 工作完成后的清理工作
            // 释放回调函数的引用            napi_delete_reference(env, callbackRef);        },    );
    // 将工作入队，在ArkTS线程中执行    napi_queue_async_work(env, work);}

createCPlusPlusThread(env, (result: number) => {    // 处理C++线程返回的结果    console.log(`Result: ${result}`);}, data);