Столкнулись с трудностью остановки потока в порождении дочернего процесса в Node.js? - PullRequest
Новая
       11

Столкнулись с трудностью остановки потока в порождении дочернего процесса в Node.js?

0 голосов
/ 10 октября 2018

Я пытаюсь использовать дочерний процесс Node.js.Приведенный ниже код будет выполнять определенные команды оболочки и считывать данные как прослушиватель буферных потоков, предоставляемый процессом spawn.Модуль обещания узла Bluebird используется, чтобы обернуть дочерний процесс.

var execSpawn = require('child_process').spawn;
var Promise = require('bluebird');

spawnAction = function(path, cmd, cb){
return function(resolve, reject){
    cmdExec = execSpawn(path, cmd);
    var fileData = {}
    var count = 0;
    cmdExec.stdout.on('data', function(data){
        if(cb){
            fileData = data.toString('utf8');
        }else{
            if(data =='.'){
                count +=1;
            }else{
                console.log(data.toString('utf8'));
            }
        }
    });
    cmdExec.stderr.on('data', function(data){
        if(reject){
            reject("error in scrubbing "+cmd.slice(-1) + " "+data.toString('utf8'));
        }
    });
    cmdExec.on('exit', function(){
     console.log("reach the exit event");
    })
    cmdExec.on('close', function(){
        if(cb){
            resolve(cb(fileData));
        }else{
            resolve(count);
        }
    });
}

}

Вышеупомянутый метод вызывается несколько раз для параллельного выполнения, используя следующие способы: 

promises = []
cp = new Promise(spawnAction(Path, ['cmd'],parsingMethodHandler));
cp.then(function(data){
    data.forEach(function(disk){
       var handler = new Promise(self.spawnAction(Path, "next command"));
       promises.push(handler);
   }
}.then(function(){
    Promise.all(promises).then(function(result){
        //certain actions
    }.catch(function(err){
        //catch error specific to the failure of promise handler
    })
}).catch(function(err){
  //error specific to the first promise
    })

И моя проблема заключается в том, если в случае какой-либо ошибки во времявыполнение любого обещания должно достигнуть "cmdExec.stderr.on" и выполнить отклонение обещания.Даже после того, как из-за ошибки я получаю консольные журналы, помещенные в потоки cmdExec.stdout.on, я не мог прекратить получать потоки буфера.

Я хотел бы знать, есть ли какой-либо конкретный способ остановить выполнение дочернего процесса, если он сталкивается с какой-либо ошибкой и останавливается, выбрасывая ошибку вместо продолжения получения потоков.

Заранее спасибоза любые предложения или идеи.

1 Ответ

0 голосов
/ 14 октября 2018

Спасибо за комментарии и предложения.Я нашел способ решить проблему остановки Eventlistener, привязанного к порождению дочернего процесса.В приведенном выше коде каждый раз, когда promisall вызывается и, в свою очередь, запускает несколько обработчиков с процессом spawn, созданным вместе с различными слушателями.Если в одном из процессов порождения по обещанию произошла одна ошибка, нужно будет сгенерировать ошибку и немедленно остановить все созданные процессы порождения.

Мое решение - сохранить весь процесс порождения во время создания в массиве.При возникновении ошибки с одним из процессов вызова вызовет прерывание «SIGINT», чтобы немедленно завершить все действия.Это немедленно останавливает выполнение процесса и выдает ошибку.Вы можете найти фрагмент кода ниже 

var execSpawn = require('child_process').spawn;
var Promise = require('bluebird');

var child_process_list = []

var spawnAction = function(path, cmd, cb){
    return function(resolve, reject, onCancel){
        cmdExec = execSpawn(path, cmd);
        child_process_list.push(cmdExec);
        var fileData = {}
        var count = 0;

        cmdExec.stdout.setEncoding('utf8');
        cmdExec.stdout.on('data', function(data){
            //Certain actions with filedata and count;
            console.log(data);
        });
        cmdExec.stderr.on('data', function(data){
            while(child_process_list.length > 0){
                proc = child_process_list.pop();
                proc.kill('SIGINT');
            }
            if(reject){
                reject("error "+cmd.slice(-1) + " "+data.toString('utf8'));
            }
        });

        cmdExec.on('close', function(){
                if(cb){
                   resolve(cb(fileData));
                }else{
                    resolve(count);
                }
        });
       }
    }

var handle = function(path, cmd, cb) {
    var promises = []
    cp = new Promise(spawnAction(path, ['cmd'],parsingMethodHandler));
    cp.then(function(data){
        data.forEach(function(disk){
            cmd.push(disk);
            var handler = new Promise(self.spawnAction(path, cmd));
            promises.push(handler);
        });
    }).then(function(){
        Promise.all(promises).then(function(result){
            console.log("result => ",result);
            child_process_list = [];
            cb();
        }).catch(function(err){
            console.log("error call => ",err);
            cb();
        })
    }).catch(function(err){
        console.log("Failed in fetching drive path available ",err);
        cb()
    })     
}

Я хотел бы проверить свой подход и сообщить, что для решения этой ситуации доступен лучший подход.Заранее спасибо.

...