node c++多线程插件构想

最近想写一个node的c++插件实现线程。提供的api使用回调并进行二次包装使其返回一个promise，并且要求需要在工作线程里执行的函数为async函数。如果是node7.0以下的版本，函数必须返回一个promise对象

目前还在构想api列表，我本身并不懂c++，感觉和学过的c#相差太大，总之就是非常难的感觉，很多地方完全不能理解。按照网上的hello world写出来发现不对，在官网查结果api改了，那个气啊。

构想的api现在只有几个

Thread=require('thread');                      //引用

new Thread(fn[async],args);                  //创建一个线程

thr.id;                                                     //windows下thr的managedId

thr.start();                                              //启动线程，返回一个promise对象，可用await接收

thr.abort();                                             //中断线程，将触发promise的reject状态

thr.sleep(ms);                                         //阻塞线程，默认永久阻塞

thr.restart();                                           //重开阻塞的线程，如果没有阻塞，忽略此操作

thr.wait();                                               //当前线程等待该线程执行完毕

                                                               //用于不支持async/await的node版本

Thread.pool;                                           //获取线程池

pool.maxSize;                                         //get/set 线程池的最大尺寸

pool.minSize;                                          //get/set 线程池的最小尺寸

pool.workingCount;                                 //get 正在执行任务的工作线程数

pool.run(fn[async],args);                        //启动工作线程执行函数，返回promise

Thread.current;                                       //获取当前线程，允许在线程池里使用

                                                                //线程池里获取的线程不支持abort函数

Thread.lock(src);                                     //为资源上锁，同一时间只允许一个线程访问该资源

目前这只是一个构想，还没有实现，我在学习c++，最近因为考驾照比较忙，如果实现了，就可以如下使用代码。

const Thread = require(`thread`);
const threadPool = Thread.pool;

threadPool.run(async function (src) {
    try {
        let txt = require('fs').readFileSync(src)
        console.log(`结果为${result}`);
    }
    catch (err) {
        throw err;
    }
}, '1.txt');


//这里是一个死循环，在单线程的node里是绝对没有办法执行上面的console.log操作的
//但是这里使用多线程，使用子线程打印，主线程一直打印占用
while (true) {
    console.log(`主线程一直被占用`);
}

上面的例子还演示了fs.readFile可以写成如下

const Thread = require(`thread`);
const threadPool = Thread.pool;

/**
 * @param {String} src 要读取的文件路径
 * @param {String} encode 编码
 * @return {Promise} 
 */
// 这个函数虽然直接返回promise，但是由于理解方便，所有返回promise的函数都用async标记
async function readFile(...args) {
    return threadPool.run(async () => {
        try {
            let result = require('fs').readFileSync(...args);
            return result;
        }
        catch (err) {
            throw err;
        }
    })
}

/**
 * 这个函数使用自带的fs.readFile改写成promise的形式
 * 但还是上面的同步的方式看起来更舒服
 */
async function readFile(src, encode) {
    return new Promise((resolve, reject) => {
        let args = [src];
        if (encode) args.push(encode);
        args.push((err, data) => {
            if (err) reject(err);
            else resolve(data);
        })

        require('fs').readFile(...args);
    })
}


//最终用async函数调用
(async function main() {
    try {
        let txt = await readFile('1.txt', 'utf-8');
        console.log(txt);
    }
    catch (err) {
        console.log(`出错啦，信息:${err.message}`);
    }
} ());