Node.js模块同步到异步

Node.js module sync to async

本文关键字：异步 同步 模块 js Node      更新时间：2023-09-26

我有一个简单的Node.js模块，它获取一个Handlebars模板目录，编译它们，然后导出一个基于它们名称的对象：

'use strict';
var
  fs = require('fs'),
  path = require('path'),
  handlebars = require('handlebars'),
  templateDir = __dirname + '/templates/',
  templates = {};
fs.readdirSync(templateDir).forEach(function (file) {
  templates[path.basename(file, path.extname(file))] =
    handlebars.compile(fs.readFileSync(templateDir + file));
});
module.exports = templates;

所以在其他模块中，我可以：

var templates = require('./templates');
templates[SOME_TEMPLATE]({ ... });

不过，我正在努力解决如何异步执行此操作，特别是如何在混合中使用发射器进行导出。

var emitter = require('events').EventEmitter;
module.exports = function (callback) {
  emitter.on('templates-compiled', function () {
    callback(templates);
  });
  callback();
};
fs.readdir(templateDir, function (err, files) {
  if (!err) {
    files.forEach(function (file) {
      fs.readFile(templateDir + file, function(err, data) {
        if (!err) {
          templates[path.basename(file, path.extname(file))] =
            handlebars.compile(data);
          if (files[files.length - 1] === file) {
            emitter.emit('templates-compiled');
          }
        } else {
        }
      });
    });
  } else {
  }
});

以下是对上述内容的修改：

var EventEmitter = require('events').EventEmitter;
var path = require('path');
var fs = require('fs');
module.exports = function(dir, callback) {
  var emitter = new EventEmitter();
  var templates = {};
  emitter.on('templates-compiled', function(t) {
    callback(null, t);
  });
  emitter.on('templates-error', function(e) {
    callback(e);
  });
  fs.readdir(dir, function(err, files) {
    if (!err) {
      files.forEach(function(file) {
        fs.readFile(path.join(dir, file), function(err, data) {
          if (!err) {
            //note: i'm just calling toString() here - do your compile here instead
            templates[path.basename(file, path.extname(file))] = data.toString();
            if (files[files.length - 1] === file) {
              emitter.emit('templates-compiled', templates);
            }
          } else {
            emitter.emit('templates-error', err);
          }
        });
      });
    } else {
       emitter.emit('templates-error', err);
    }
  });
};

然而，您可能需要考虑使用q或async来修剪厄运金字塔。

相关文章：