关键词:
这篇文章来实现的是在C/C++插件中,实现Native Promise, 调用 Native Thread执行后台任务, 执行玩后台任务后,返回到JS前端, JS前端可以通过 await关键字等待返回。
Promise实现原理
下面一些封装是实现本插件的核心,没有什么文档具体只能去看源码案例分析。
Napi::Promise::Deferred //Promise C/C++实现对象
Napi::Promise::Deferred::Resolve() // 相对于js promise的resolve()
Napi::Promise::Deferred::Promise() // 相对于js promise的promise()
Napi::ThreadSafeFunction::New() //实现一个线程安全的js函数
std::thread //c++11 异步线程的实现
实现效果如下
异步顺序输出时间后,js函数最后返回true,实现代码在
js端调用调用代码如下
const createTSFN = require('bindings')('addon.node');
//异步执行C/C++插件回调
const callback = (...args) =>
console.log(new Date, ...args);
;
void async function()
//await等待
let ret=await createTSFN(callback) ;
console.log(ret);
();
C/C++插件代码如下
#include <chrono>
#include <thread>
#include "napi.h"
constexpr size_t ARRAY_LENGTH = 10;
// 定义线上安全结构上下文
struct TsfnContext
TsfnContext(Napi::Env env) : deferred(Napi::Promise::Deferred::New(env))
for (size_t i = 0; i < ARRAY_LENGTH; ++i) ints[i] = i;
;
// 本地Promise到js返回
Napi::Promise::Deferred deferred;
// 本地线程
std::thread nativeThread;
// Some data to pass around
int ints[ARRAY_LENGTH];
//线程安全函数
Napi::ThreadSafeFunction tsfn;
;
void threadEntry(TsfnContext* context)
auto callback = [](Napi::Env env, Napi::Function jsCallback, int* data)
jsCallback.Call(Napi::Number::New(env, *data));
;
for (size_t index = 0; index < ARRAY_LENGTH; ++index)
//执行对JavaScript的调用
napi_status status =
context->tsfn.BlockingCall(&context->ints[index], callback);
if (status != napi_ok)
Napi::Error::Fatal(
"ThreadEntry",
"Napi::ThreadSafeNapi::Function.BlockingCall() failed");
// 休眠
std::this_thread::sleep_for(std::chrono::milliseconds(200));
// 释放线程安全函数
//创建几个就释放几次
context->tsfn.Release();
//垃圾清理 类似js上下文析构函数
void FinalizerCallback(Napi::Env env,
void* finalizeData,
TsfnContext* context)
//等待本地thread结束
context->nativeThread.join();
//await createTSFN()返回 true
context->deferred.Resolve(Napi::Boolean::New(env, true));
delete context;
// 创建线程安全函数和本地线程
Napi::Value CreateTSFN(const Napi::CallbackInfo& info)
//js引擎环境
Napi::Env env = info.Env();
// 构造上下文数据
auto ctxData = new TsfnContext(env);
// 创建一个线程安全函数
ctxData->tsfn = Napi::ThreadSafeFunction::New(
env, // Environment
info[0].As<Napi::Function>(), // js回调函数
"TSFN22", // 随意名字
0, // 最大队列数
1, // 初始化线程数量
ctxData, // 自定义上下文,
FinalizerCallback, // 析构函数
(void*)nullptr // 析构函数 数据
);
//创建本地线程
ctxData->nativeThread = std::thread(threadEntry, ctxData);
// 函数的终结回调
return ctxData->deferred.Promise();
//createTSFN入口
Napi::Object Init(Napi::Env env, Napi::Object exports)
exports["createTSFN"] = Napi::Function::New(env, CreateTSFN);
return exports;
NODE_API_MODULE(addon, Init)
至此我们实现了Native Promise的封装
node.js插件编写-普通函数和回调函数的实现
前言前两节我们讲述了node插件的基础入门,以及需要的环境,这一节我们来尝试写一个复杂一点的插件,通过Node-Api实现插件导出普通函数和回调函数。环境安装 安装bindings依赖 以及node-addon-api 依赖 相关package.json文... 查看详情
node.js插件编写-普通函数和回调函数的实现(代码片段)
前言前两节我们讲述了node插件的基础入门,以及需要的环境,这一节我们来尝试写一个复杂一点的插件,通过Node-Api实现插件导出普通函数和回调函数。环境安装 安装bindings依赖 以及node-addon-api 依赖 相关package.json文... 查看详情
node.js插件编写-函数工厂与对象工厂的实现(代码片段)
这篇文章我们通过通过nodejs插件完成 函数工厂和对象工厂的例子。首先看下面这段node.js代码 ,我们引用的my_node_addon插件需要导出createFunc函数和createObject函数, 并且createObject函数返回的对象包含 add和addCallback... 查看详情
node.js插件编写-函数工厂与对象工厂的实现(代码片段)
这篇文章我们通过通过nodejs插件完成 函数工厂和对象工厂的例子。首先看下面这段node.js代码 ,我们引用的my_node_addon插件需要导出createFunc函数和createObject函数, 并且createObject函数返回的对象包含 add和addCallback... 查看详情
node.js插件编写-通过node-api编写简单插件入门(代码片段)
在编写Node插件之前我们首先要了解一下node.js插件的编写方式,我们今天采用的是三种方式之一的Node-Api进行编写,采用C++实现,根据下面步骤你也可以编写自己的插件。但是编写插件需要有C/C++基础,如果没有基础那么建议忽略本文... 查看详情
node.js插件编写-异步asyncworker的代码实现(代码片段)
异步介绍我们在Node.js中经常用到异步机制,比如异步改变一个文件的访问权限,然后任务完成之后我们收到一个回调通知:代码如下:importchmodfrom'fs';chmod('chmod.txt',0o775,(err)=>console.log('Thepermissionsforfile"my_file.txt... 查看详情
node.js插件编写-异步asyncworker的代码实现(代码片段)
异步介绍我们在Node.js中经常用到异步机制,比如异步改变一个文件的访问权限,然后任务完成之后我们收到一个回调通知:代码如下:importchmodfrom'fs';chmod('chmod.txt',0o775,(err)=>console.log('Thepermissionsforfile"my_file.txt... 查看详情
node.js插件编写-异步asyncworker的代码实现(代码片段)
异步介绍我们在Node.js中经常用到异步机制,比如异步改变一个文件的访问权限,然后任务完成之后我们收到一个回调通知:代码如下:importchmodfrom'fs';chmod('chmod.txt',0o775,(err)=>console.log('Thepermissionsforfile"my_file.txt... 查看详情
node.js插件编写-普通函数和回调函数的实现(代码片段)
前言前两节我们讲述了node插件的基础入门,以及需要的环境,这一节我们来尝试写一个复杂一点的插件,通过Node-Api实现插件导出普通函数和回调函数。环境安装 安装bindings依赖 以及node-addon-api 依赖 相关package.json文件内容如下 &... 查看详情
node.js插件编写-通过node-api编写简单插件入门(代码片段)
在编写Node插件之前我们首先要了解一下node.js插件的编写方式,我们今天采用的是三种方式之一的Node-Api进行编写,采用C++实现,根据下面步骤你也可以编写自己的插件。但是编写插件需要有C/C++基础,如果没有基础那么建... 查看详情
node.js插件编写-通过node-api编写简单插件入门(代码片段)
在编写Node插件之前我们首先要了解一下node.js插件的编写方式,我们今天采用的是三种方式之一的Node-Api进行编写,采用C++实现,根据下面步骤你也可以编写自己的插件。但是编写插件需要有C/C++基础,如果没有基础那么建... 查看详情
node.js插件编写-创建类原型以及类工厂(代码片段)
...厂和对象工厂的实现,这篇文章我们进一步完善,通过Node.js插件导出类原型,以及导出一个类工厂函数。我们要让编写的插件导出的类支持new关键字,以及可以通过函数直接返回对象,具体js代码如下:varaddon=require(\'bindings\')(\'my_node_addo... 查看详情
node.js插件编写-创建类原型以及类工厂(代码片段)
...厂和对象工厂的实现,这篇文章我们进一步完善,通过Node.js插件导出类原型,以及导出一个类工厂函数。我们要让编写的插件导出的类支持new关键字,以及可以通过函数直接返回对象,具体js代码如下:varaddon=require(\'bindings\')(\'my_node_addo... 查看详情
node.js插件编写-函数工厂与对象工厂的实现(代码片段)
这篇文章我们通过通过nodejs插件完成 函数工厂和对象工厂的例子。首先看下面这段node.js代码 ,我们引用的my_node_addon插件需要导出createFunc函数和createObject函数, 并且createObject函数返回的对象包含 add和addCallback两个加法函数vara... 查看详情
无法连接到本地 Node.js 安全 WebSocketServer
】无法连接到本地Node.js安全WebSocketServer【英文标题】:Can\'tconnecttolocalNode.jssecureWebSocketServer【发布时间】:2019-06-0616:19:00【问题描述】:为了测试JavaScript/html5应用程序,我使用node.js和wspackage创建了一个本地WebSocketServer。我想通... 查看详情
node.js插件编写-通过nan编写简单插件入门(代码片段)
上一篇文章我们介绍了通过Node-Api的方式编写一个插件,并且导出一个函数hello,这篇文章我们介绍另一种插件开发方式NAN,NAN是出现在Node-Api之前的一种插件开发方式,采用的也是C++的封装。读本文内容仍然需要有C/C++开发基础,如没... 查看详情
node.js插件编写-创建类原型以及类工厂(代码片段)
...厂和对象工厂的实现,这篇文章我们进一步完善,通过Node.js插件导出类原型,以及导出一个类工厂函数。我们要让编写的插件导出的类支持new关键字,以及可以通过函数直接返回对象,具体js代码如下:varaddon=require(\'bindings\')(\'my_node_addo... 查看详情
node.js插件编写-通过nan编写简单插件入门(代码片段)
上一篇文章我们介绍了通过Node-Api的方式编写一个插件,并且导出一个函数hello,这篇文章我们介绍另一种插件开发方式NAN,NAN是出现在Node-Api之前的一种插件开发方式,采用的也是C++的封装。读本文内容仍然需要有C/C++开... 查看详情