1

私のメイン Node インスタンスは、 Kueに追加する新しいジョブに関する情報を含むオブジェクトである(組み込みの Nodeprocess.send()とを使用して) IPC 経由でメッセージを受け入れるワーカー プロセスを fork します。次に、それらのジョブを処理します。process.on('message'...

私のメイン Node インスタンスは次のように呼び出します。

worker.send({jobType:'filesystem', operation: 'delete', path: fileDir});

ワーカー インスタンスは次のように動作します。

jobs.create(message.jobType, message).save();

jobs.process('filesystem', function(job, done) {
    fs.delete(job.data.path, function(err) {
        done(err);
    });
});

ジョブは正常に完了します。

ジョブが完了したときにメイン Node インスタンスでコールバックのような機能を取得するにはどうすればよいですか? ワーカー インスタンスからメイン ノード インスタンスに結果を返すにはどうすればよいですか?

4

1 に答える 1