yqthen.js
**写这个流程库的目的不是为了解决异步回调，而是为了最大限度的挖掘js异步模型的优势。将js的长处发挥到极致 **
async/await确实能写出这个好看的代码，但是我这是流程库啊。。。。 我比较和参考的对象是 async或者thenjs 才是啊。 而且我这个库很适合用来写脚本，你总不能写脚本的时候把方法单独拉出来，封装一遍吧。
1.async常用的API在这里都可以进行链式调用，并且API更加友好。 2.这个库在并发处理上有长处，会让写出的程序有一定的性能提升。
例如下面的例子中 你需要打开数据库和读取文件，耗时都为100MS； 如果用下面的promise形式的话，需要200MS才能完成。generator和await也是200MS;
then(()=>{ db.open() }).then(()=>{ fs.readFile() })
如果用这个库的go方法的话 可以并发完成 只需要100MS，go链里的方法都是并发运行，当go链运行结束后会继续运行then链。
then.go(()=>{ db.open() }).go(()=>{ fs.readFile() }).then...
这样简单的处理,程序的性能就拉开了100MS，而且代码也变得更加美观。
测试用例
业务要求 要求:并发读取文件和打开数据库连接。存入数据库都是并发。 读取一个helloJs.text文件,并将内容保存到’DBXXX’数据库中， 在将该数据提交给远程服务器,地址http:XXX。 如果提交成功，在把文件转成行，每一行一条记录，存到DBXXX数据库中。
伪代码： 一般java或php代码的写法
try{
file = readFile('helloJs.text'); //读取文件
db = DB.open('DBXXX'); //打开数据库
db.save(file); //数据库保存数据
request('http:xxx',file); //像服务器提交数据
lines = file.convertLine;//转换成行
for(var i=0;i<lines.length;i++){
db.save(lines[i]); //每行一条数据，保存到数据库
}
}catch(e){
echo e //捕获异常
}
代码貌似没有问题，但是这里读取文件和打开数据库的操作是可以同时运行的， 如果java用实现的话，可能就要使用多线程模型了。
如果用js实现的话，我想大家都会。 但是用这个库写出来的代码绝对是最简洁优美的。 这里的读取文件和打开数据库是并发的。 yqthen
var then = require('yqthen');
var file,db;
then
.go((next)=>{
readFile('helloJs.text',(err,file)=>{ //读取文件
file = file;
next(err);
})
})
.go((next)=>{
DB.open('DBXXX',(err,db)=>{ //打开数据库
db = db;
next(err);
})
})
.then((next)=>{
db.save(file,(err)=>{ //数据库保存数据
next(err);
})
}).then((next)=>{
request('http:xxx',file,(err)=>{ //像服务器提交数据
next(err);
})
})
.each(file.convertLine,(next,line)=>{
db.save(line,(err)=>{ //每行一条记录保存到数据库
next(err);
})
})
.then((next)=>{
callback(null); //操作成功
})
.fail((next,err)=>{
callback(err); //捕获异常
})
这里在特地比较一下async
async.waterfall([
function(callback){
async.parallel([ //并行运行
function(){ //读取文件
readFile('helloJs.text',(err,file)=>{ //读取文件
file = file;
})
},
function(){ //打开数据库
DB.open('DBXXX',(err,db)=>{ //打开数据库
db = db;
})
}
],
function(err, results){
callback(null, fs, db,callback);
});
},
function(fs, db, callback){
request('http:xxx',file,(err)=>{ //像服务器提交数据
callback(null,fs,db);
})
},
function(fs,db, callback){
async.eachSeries(fs.convertLine, function iteratee(line, callback) { //循环并发
db.save(line,(err)=>{ //每行一条记录保存到数据库
callback(err);
})
});
}
], function (err, result) {
console.log(err,result);
});
//我已经被这个嵌套搞崩溃了！！！
传送门： yqthen
虽然用了yqthen框架，但是异步代码还是没有同步代码简洁，这也是没有办法的事，希望js能像 形式同步更近一点。
但是我这里读取文件和打开数据库用go链连接，也就说这两个方法是并发的，是同时运行的。只有当 这两步操作成功后，才会像数据库保存数据，最后在向服务器提交数据。
- 我很非常喜欢node也热爱开源，如果大家觉得还行，请给我一个星星 鼓励一下吧。