/
thread.js
36 lines (33 loc) · 919 Bytes
/
thread.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
const { Worker, isMainThread, parentPort, workerData } = require('worker_threads');
const cp = require('child_process')
const helpParse = require('./helpParser');
if (isMainThread) {
module.exports = cmdParser;
/**
* @function
* @param {String} cmd
* @returns {Promise<Object>}
*/
function cmdParser(cmd) {
return new Promise((resolve, reject) => {
const worker = new Worker(__filename, {
workerData: cmd
});
worker.once('message', msg => {
worker.unref()
resolve(msg)
});
worker.on('error', reject);
worker.on('exit', (code) => {
if (code !== 0)
reject(new Error(`Worker stopped with exit code ${code}`));
});
});
};
} else {
const cmd = workerData;
cp.exec(cmd + ' --help', {encoding: 'utf8'}, (err, stdout, stdin) => {
const help = helpParse(stdout)
parentPort.postMessage(help)
})
}