nodejs异步流程控制

Posted 2021-09-15 月疯

场景：

1、图片上传服务器

2、图片写入磁盘

3、图片写入数据库

在nodejs里面这三种方式都是异步操作，不想java其他语言同步进行，这就需要对异步流程进行控制，保证1,2,3逐步进行。有可能1还没完成，2和3可能就开始了，所以需要控制流程。

异步流程控制对象async
1、串行无关联：async.series（1,2,3按照顺序执行）
2、并行无关联：async.parallel（1,2,3一起跑）
3、串行有关联：waterfall（瀑布流关系，1完成传给2,2完成传给3）
4、parallelLimit：parallelLimit函数和parallel类似，但是它多了一个参数limit。（同一时间只能并行2个或者三个任务）
limit参数限制任务只能同时并发一定数量，而不是无限制并发
 

 先要进行安装：npm install async --save-dev

 

 串行无关联：async.series测试：

let async=require('async');
function exec(){
    async.series({
        one:function(done){
            ii=0;
            setInterval(function(){
                console.log('aaa='+new Date());
                ii++;
                if(ii==3){
                    clearInterval(this);
                    done(null,'one完毕');
                }
            },1000);
        },
        two:function(done){
            jj=0;
            setInterval(function(){
                console.log('bbb='+new Date());
                jj++;
                if(jj==3){
                    clearInterval(this);
                    done(null,'two完毕');
                }
            },1000);

        }
    },function(err,rs){
        console.log(err);
        console.log(rs);
    })
}
exec();
console.log('主进程执行完毕');

 并行无关联：async.parallel测试：

let async=require('async');
function exec(){
    async.parallel({
        one:function(done){
            ii=0;
            setInterval(function(){
                console.log('aaa='+new Date());
                ii++;
                if(ii==3){
                    clearInterval(this);
                    done(null,'one完毕');
                }
            },1000);
        },
        two:function(done){
            jj=0;
            setInterval(function(){
                console.log('bbb='+new Date());
                jj++;
                if(jj==3){
                    clearInterval(this);
                    done(null,'two完毕');
                }
            },1000);

        }
    },function(err,rs){
        console.log(err);
        console.log(rs);
    })
}
exec();
console.log('主进程执行完毕');

 串行有关联：waterfall测试：

let async=require('async');
function exec(){
    //第一个的回调是第二个的参数
    async.waterfall([
        function(done){
            ii=0;
            setInterval(function(){
                console.log('aaa='+new Date());
                ii++;
                if(ii==3){
                    clearInterval(this);
                    done(null,'one完毕');
                }
            },1000);
        },
        function(preValue,done){
            jj=0;
            setInterval(function(){
                console.log('bbb='+new Date());
                jj++;
                if(jj==3){
                    clearInterval(this);
                    done(null,preValue+'two完毕');
                }
            },1000);

        }
    ],function(err,rs){
        console.log(err);
        console.log(rs);
    })
}
exec();
console.log('主进程执行完毕');