我正在尝试使用 NAPI 创建 Node 模块。我必须创建返回 promise 的异步函数。我不希望 testasynfunction 会阻塞 NodeJS 事件循环。 do_something_asynchronous 是一个同步函数。
napi_deferred do_something_synchronous(napi_env env,napi_deferred deferred){
printf("\n3) Function called");
//napi_deferred deferred;
napi_value undefined;
napi_status status;
// Create a value with which to conclude the deferred.
status = napi_get_undefined(env, &undefined);
if (status != napi_ok) return NULL;
sleep(5);
// Resolve or reject the promise associated with the deferred depending on
// whether the asynchronous action succeeded.
if (false) {
printf("\n5) Success\nXXXXXXX");
status = napi_resolve_deferred(env, deferred, undefined);
} else {
printf("\nReject");
status = napi_reject_deferred(env, deferred, undefined);
}
if (status != napi_ok) return NULL;
// At this point the deferred has been freed, so we should assign NULL to it.
deferred = NULL;
}
//Function will be called from the js
napi_value testasynfunction(napi_env env, napi_callback_info info){
printf("XXXXX Hello \n");
napi_deferred deferred;
napi_value promise;
napi_status status;
// Create the promise.
status = napi_create_promise(env, &deferred, &promise);
if (status != napi_ok) return NULL;
printf("\n1) Calling function to do something");
do_something_synchronous(env,deferred);
//std::async(do_something_asynchronous,env,deferred);
printf("\n2) Returning Promise");
return promise;
}
napi_property_descriptor testasync = DECLARE_NAPI_METHOD("testasyn", testasynfunction);
status = napi_define_properties(env, exports, 1, &testasync);
assert(status == napi_ok);
NAPI_MODULE(NODE_GYP_MODULE_NAME, Init)
问题 :
1)我怎样才能异步运行do_something_synchronous,以便nodejs事件循环不会被阻塞并返回 promise ?
最佳答案
以下代码片段是此异步操作的关键组件。
napi_create_async_work() 函数分配一个工作对象,我们可以在其中指定工作处理函数,例如在我们的例子中 执行我的 promise 1 ()(可以部署长时间运行或处理繁重的任务)。 此函数将排队等待工作池线程 和 它将与 node.js 主事件循环线程同步异步执行 .
到目前为止一切正常,当 ExecuteMyPromise1 函数计划直接从工作线程与 JavaScript 层交换结果时,问题就会出现。 任何 JavaScript 操作通常只能从 native 插件的主线程调用 .然后对于这个结果交换,我们必须使用另一个从主线程调用的 native 函数。这就是我们使用 的原因。 CompleteMyPromise1 函数处理程序(如果任何最终清理事件也从此函数完成)。当异步逻辑完成或取消时,将从主事件循环线程调用此原生函数。
// The function called by javascript to get a promise returned.
napi_value MyPromise1(napi_env env, napi_callback_info info)
{
// -- -- -- --
// -- -- -- --
// Create a promise object.
status = napi_create_promise(env, &promDataEx->deferred, &promise);
if (status != napi_ok)
{
napi_throw_error(env, NULL, "Unable to create promise.");
}
// -- -- -- --
// -- -- -- --
{
// Create the async function.
napi_value resource_name;
napi_create_string_utf8(env, "MyPromise1", -1, &resource_name);
napi_create_async_work(env, NULL, resource_name,
ExecuteMyPromise1, CompleteMyPromise1,
promDataEx, &promDataEx->work);
napi_queue_async_work(env, promDataEx->work);
}
return promise;
}
// Execute the asynchronous work.
void ExecuteMyPromise1(napi_env env, void *data)
{
prom_data_ex_t *promDataEx = (prom_data_ex_t *)data;
// Calculate prime count
promDataEx->PrimeCount = CPrimeCount( promDataEx->x, promDataEx->y );
// Set the status as asynchronous_action is success
promDataEx->asynchronous_action_status = 0;
//sleep(3);
}
// Handle the completion of the asynchronous work.
void CompleteMyPromise1(napi_env env, napi_status status, void *data)
{
napi_value rcValue;
prom_data_ex_t *promDataEx = (prom_data_ex_t *)data;
napi_create_int32(env, promDataEx->PrimeCount, &rcValue);
// Resolve or reject the promise associated with the deferred depending on
// whether the asynchronous action succeeded.
if ( promDataEx->asynchronous_action_status == 0) // Success
{
status = napi_resolve_deferred(env, promDataEx->deferred, rcValue);
}
else
{
napi_value undefined;
status = napi_get_undefined(env, &undefined);
status = napi_reject_deferred(env, promDataEx->deferred, undefined );
}
if (status != napi_ok)
{
napi_throw_error(env, NULL, "Unable to create promise result.");
}
napi_delete_async_work(env, promDataEx->work);
free(promDataEx);
}
这是它的完整示例代码
https://github.com/msatyan/MyNodeC/blob/master/src/mync1/MyPromise1.cpp
JavaScrip 调用是 TestPromiseWithAsync()
https://github.com/msatyan/MyNodeC/blob/master/test/TestExtensions.js
关于javascript - 如何使用返回 Promises 的 NAPI 创建异步函数,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/62214214/