鸿蒙（API 12 Beta2版）NDK开发【使用Node-API接口进行异步任务开发】

使用Node-API接口进行异步任务开发

场景介绍

napi_create_async_work是Node-API接口之一，用于创建一个异步工作对象。可以在需要执行耗时操作的场景中使用，以避免阻塞主线程，确保应用程序的性能和响应性能。例如以下场景：

文件操作：读取大型文件或执行复杂的文件操作时，可以使用异步工作对象来避免阻塞主线程。
网络请求：当需要进行网络请求并等待响应时，使用异步工作对象可以确保主线程不被阻塞，从而提高应用程序的响应性能。
数据库操作：当需要执行复杂的数据库查询或写入操作时，使用异步工作对象可以确保主线程不被阻塞，从而提高应用程序的并发性能。
图像处理：当需要对大型图像进行处理或执行复杂的图像算法时，使用异步工作对象可以确保主线程不被阻塞，从而提高应用程序的实时性能。

异步调用支持callback方式和Promise方式，使用哪种方式由应用开发者决定，通过是否传递callback函数进行区分。

使用Promise方式示例

使用napi_create_async_work创建异步任务，并使用napi_queue_async_work将异步任务加入队列，等待执行。

struct CallbackData {napi_async_work asyncWork = nullptr;napi_deferred deferred = nullptr;napi_ref callback = nullptr;double args = 0;double result = 0;
};static napi_value AsyncWork(napi_env env, napi_callback_info info)
{size_t argc = 1;napi_value args[1];napi_get_cb_info(env, info, &argc, args, nullptr, nullptr);napi_value promise = nullptr;napi_deferred deferred = nullptr;napi_create_promise(env, &deferred, &promise);auto callbackData = new CallbackData();callbackData->deferred = deferred;napi_get_value_double(env, args[0], &callbackData->args);napi_value resourceName = nullptr;napi_create_string_utf8(env, "AsyncCallback", NAPI_AUTO_LENGTH, &resourceName);// 创建异步任务napi_create_async_work(env, nullptr, resourceName, ExecuteCB, CompleteCB, callbackData, &callbackData->asyncWork);// 将异步任务加入队列napi_queue_async_work(env, callbackData->asyncWork);return promise;
}

定义异步任务的第一个回调函数，该函数在工作线程中执行，处理具体的业务逻辑。

static void ExecuteCB(napi_env env, void *data)
{CallbackData *callbackData = reinterpret_cast<CallbackData *>(data);callbackData->result = callbackData->args;
}

定义异步任务的第二个回调函数，该函数在主线程执行，将结果传递给ArkTS侧。

static void CompleteCB(napi_env env, napi_status status, void *data)
{CallbackData *callbackData = reinterpret_cast<CallbackData *>(data);napi_value result = nullptr;napi_create_double(env, callbackData->result, &result);if (callbackData->result > 0) {napi_resolve_deferred(env, callbackData->deferred, result);} else {napi_reject_deferred(env, callbackData->deferred, result);}napi_delete_async_work(env, callbackData->asyncWork);delete callbackData;
}

模块初始化以及ArkTS侧调用接口。

// 模块初始化
static napi_value Init(napi_env env, napi_value exports)
{napi_property_descriptor desc[] = {{ "asyncWork", nullptr, AsyncWork, nullptr, nullptr, nullptr, napi_default, nullptr }};napi_define_properties(env, exports, sizeof(desc) / sizeof(desc[0]), desc);return exports;
}// ArkTS侧调用接口
nativeModule.asyncWork(1024).then((result) => {hilog.info(0x0000, 'XXX', 'result is %{public}d', result);}
);

使用callback方式示例

使用napi_create_async_work创建异步任务，并使用napi_queue_async_work将异步任务加入队列，等待执行。

struct CallbackData {napi_async_work asyncWork = nullptr;napi_ref callbackRef = nullptr;double args[2] = {0};double result = 0;
};napi_value AsyncWork(napi_env env, napi_callback_info info) 
{size_t argc = 3;napi_value args[3];napi_get_cb_info(env, info, &argc, args, nullptr, nullptr);auto asyncContext = new CallbackData();// 将接收到的参数保存到callbackDatanapi_get_value_double(env, args[0], &asyncContext->args[0]);napi_get_value_double(env, args[1], &asyncContext->args[1]);// 将传入的callback转换为napi_ref延长其生命周期，防止被GC掉napi_create_reference(env, args[2], 1, &asyncContext->callbackRef);napi_value resourceName = nullptr;napi_create_string_utf8(env, "asyncWorkCallback", NAPI_AUTO_LENGTH, &resourceName);// 创建异步任务napi_create_async_work(env, nullptr, resourceName, ExecuteCB, CompleteCB, asyncContext, &asyncContext->asyncWork); // 将异步任务加入队列napi_queue_async_work(env, asyncContext->asyncWork);return nullptr;
}

定义异步任务的第一个回调函数，该函数在工作线程中执行，处理具体的业务逻辑。

static void ExecuteCB(napi_env env, void *data) 
{CallbackData *callbackData = reinterpret_cast<CallbackData *>(data);callbackData->result = callbackData->args[0] + callbackData->args[1];
}

定义异步任务的第二个回调函数，该函数在主线程执行，将结果传递给ArkTS侧。

static void CompleteCB(napi_env env, napi_status status, void *data) 
{CallbackData *callbackData = reinterpret_cast<CallbackData *>(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);napi_call_function(env, undefined, callback, 1, callbackArg, &result);// 删除napi_ref对象以及异步任务napi_delete_reference(env, callbackData->callbackRef);napi_delete_async_work(env, callbackData->asyncWork);delete callbackData;
}

模块初始化以及ArkTS侧调用接口。

// 模块初始化
static napi_value Init(napi_env env, napi_value exports)
{napi_property_descriptor desc[] = {{ "asyncWork", nullptr, AsyncWork, nullptr, nullptr, nullptr, napi_default, nullptr }};napi_define_properties(env, exports, sizeof(desc) / sizeof(desc[0]), desc);return exports;
}// ArkTS侧调用接口
let num1: number = 123;
let num2: number = 456;
nativeModule.asyncWork(num1, num2, (result) => {hilog.info(0x0000, 'XXX', 'result is %{public}d', result);
});

最后呢

很多开发朋友不知道需要学习那些鸿蒙技术？鸿蒙开发岗位需要掌握那些核心技术点？为此鸿蒙的开发学习必须要系统性的进行。

而网上有关鸿蒙的开发资料非常的少，假如你想学好鸿蒙的应用开发与系统底层开发。你可以参考这份资料，少走很多弯路，节省没必要的麻烦。由两位前阿里高级研发工程师联合打造的《鸿蒙NEXT星河版OpenHarmony开发文档》里面内容包含了（ArkTS、ArkUI开发组件、Stage模型、多端部署、分布式应用开发、音频、视频、WebGL、OpenHarmony多媒体技术、Napi组件、OpenHarmony内核、Harmony南向开发、鸿蒙项目实战等等）鸿蒙（Harmony NEXT）技术知识点

如果你是一名Android、Java、前端等等开发人员，想要转入鸿蒙方向发展。可以直接领取这份资料辅助你的学习。下面是鸿蒙开发的学习路线图。

在这里插入图片描述