发布一个异步控制流的Nodejs模块xchain

发布一个异步控制流的Node.js模块xchain

今天，我发布了一个新的Node.js模块——xchain，它旨在简化异步控制流的管理。该模块已经在npm上注册，并且已经在一些项目中得到了应用。

用途

如果你之前使用过Step库，你可能会对xchain有所了解。虽然Step非常强大，但我发现它的异常处理机制存在一些问题。因此，我设计了xchain，希望它能够更加简单且实用。

示例代码

下面是一个简单的例子，展示了如何使用xchain来管理异步操作：

var xchain = require('xchain');
var util = require('util');

xchain(
  // 在这个圆括号内的两个函数是并行执行的
  function(next) {
    setTimeout(function(){
      next.foo = 1;
      util.log('next.foo completed');
      next(); // 表示这个异步操作完成
    }, 1000); // 模拟一个用时1秒的异步操作
  },
  function(next) {
    setTimeout(function() {
      next.bar = 2;
      util.log('next.bar completed');
      next();
    }, 2000); // 模拟一个用时2秒的异步操作
  }
)(
  // xchain()返回的也是一个函数，用法和上面相同，
  // 用链式的表达式来表示依赖关系
  function(next) {
    util.log('foo=', next.foo);
    util.log('bar=', next.bar);
    throw { error: 1 }; // 抛出的异常会被传给run方法的回调捕获
  },
  function(next) {
    next();
  }
)(
  function(next) {
    throw { error: 2 };
  }
)(
  function(next) {
    // 不会执行到此处，自行揣摩传给run方法的回调
  }
).run(function(err, next) {
  if (err && err.error === 1) {
    next(); // 模拟一个可以恢复的错误
  }
  // 其他错误不处理
});

简单总结

1. 链式表达式：通过链式表达式的形式描述异步操作的依赖关系和并行关系，使得代码结构更加简洁和清晰。

2. 异步操作完成通知：异步操作完成时，将next当作函数来调用，以通知xchain当前异步操作已完成。当所有并行的操作完成后，xchain会执行下一个（批）异步操作。

3. 数据通信：为了方便数据的通信，也可以将next当作普通的对象使用（如有必要，也可以使用闭包）。

4. 运行控制流：在构建好异步控制流之后，调用run()方法开始从上而下执行。可以给run()方法传递一个异常处理函数，在异常处理函数中恢复控制流或中断控制流的执行。如果不提供异常处理函数，一旦发生异常，默认按照依赖关系停止异步控制流的执行。

总结

xchain旨在简化异步控制流的管理，提供了一种更简洁、更灵活的方式来处理复杂的异步操作。欢迎大家试用、评论和贡献代码！

• GitHub仓库: xchain
• Step库: Step

感觉很高深，我想知道这个和老赵的wind.js还有eventproxy是什么关系呢？

var xchain = require('xchain');
var con = require('console');

xchain(
  function(next) {
    setTimeout(function() {
      next({error : 1}); //异步调用中异常，不能用throw
    }, 100);
  }, 
  function(next) {
    next({error : 2});// 等价于 throw {error : 2};
  },
  function(next) {
    throw {error : 3};//等价于 next({error : 3});
  }
)(
  function(next) {
    
  }
).run(function(err, next) {
  con.log(err);
  next();
});

传给run方法的回调针对不同的异常会被调用三次