nodejs异步流程控制

朱雀 2022-09-09 09:14 192阅读 0赞

场景：

> 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

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5pyI55av_size_20_color_FFFFFF_t_70_g_se_x_16][]

**串行无关联：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('主进程执行完毕');

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5pyI55av_size_20_color_FFFFFF_t_70_g_se_x_16 1][]

**并行无关联：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('主进程执行完毕');

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5pyI55av_size_20_color_FFFFFF_t_70_g_se_x_16 2][]

**串行有关联：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('主进程执行完毕');

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5pyI55av_size_20_color_FFFFFF_t_70_g_se_x_16 3][]

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5pyI55av_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/6b8aa033c62041c2bdc7612d16bb6940.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5pyI55av_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220829/df27f0a36df241bca1259ccedcff9032.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5pyI55av_size_20_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220829/3259c48e706f4f84955933a273cfcf7e.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5pyI55av_size_20_color_FFFFFF_t_70_g_se_x_16 3]: /images/20220829/067a243cbc4a4ca1a68d9cc5f71a65d6.png

发表评论取消回复

表情：

评论列表（有 0 条评论，192人围观）

还没有评论，来说两句吧...

相关阅读

相关异步流程控制浅谈

> bash脚本语言，基本上每个命令都是需要不定时等待的，所以是一种天然的异步流程控制语言 > “我们要寻找的就是如何组织我们的代码，来让其更加容易，极少冗余的表述我们的思维

绝地灬酷狼/ 2022年10月25日 01:23/ 0 赞/ 195 阅读

相关【JS】993- JavaScript 异步流程控制

![6f32466e06b26221c22e39b138abef1d.png][] 来源 | https://github.com/cheogo/learn-javascri

不念不忘少年蓝@/ 2022年10月08日 05:32/ 0 赞/ 171 阅读

相关 nodejs异步流程控制

场景： > 1、图片上传服务器 > > 2、图片写入磁盘 > > 3、图片写入数据库 > > 在nodejs里面这三种方式都是异步操作，不想java其他语言同步进行，这

朱雀/ 2022年09月09日 09:14/ 0 赞/ 193 阅读

相关 Node js 异步执行流程控制模块Async compose

compose创建一个包括一组异步函数的函数集合，每个函数会消费上一次函数的返回值。把f(),g(),h()异步函数，组合成f(g(h()))的形式，通过callback得到返

╰+攻爆jí腚メ/ 2022年08月27日 13:50/ 0 赞/ 170 阅读

相关 node js 异步执行流程控制模块Async介绍

1.Async介绍 sync是一个流程控制工具包，提供了直接而强大的异步功能。基于Javascript为Node.js设计，同时也可以直接在浏览器中使用。 Async提

﹏ヽ暗。殇╰゛Y/ 2022年08月27日 13:49/ 0 赞/ 171 阅读

相关 Nodejs异步流程控制Async

1. Async介绍 Async是一个流程控制工具包，提供了直接而强大的异步功能。基于Javascript为Node.js设计，同时也可以直接在浏览器中使用。 Asyn

短命女/ 2022年08月18日 13:29/ 0 赞/ 261 阅读

相关 nodejs异步流程控制co 模块

万恶的回调对前端工程师来说，异步回调是再熟悉不过了，浏览器中的各种交互逻辑都是通过事件回调实现的，前端逻辑越来越复杂，导致回调函数越来越多，同时 nodejs 的流行也让

系统管理员/ 2022年06月16日 09:50/ 0 赞/ 502 阅读

相关 NodeJS -- 异步I/O

为什么要异步I/O Node是面向网络而设计的，因此，异步IO格外重要。下面，我们从两个方面来说。原因1：用户体验异步的概念之所以首先在Web中火起来，是因为

桃扇骨/ 2022年06月13日 06:58/ 0 赞/ 191 阅读

相关 nodejs异步流程控制co 模块

万恶的回调对前端工程师来说，异步回调是再熟悉不过了，浏览器中的各种交互逻辑都是通过事件回调实现的，前端逻辑越来越复杂，导致回调函数越来越多，同时 nodejs 的流行也

川长思鸟来/ 2022年05月28日 09:19/ 0 赞/ 188 阅读

相关 js中的Promise与流程控制和异步

js中的Promise与流程控制和异步文章目录 js中的Promise与流程控制和异步异步实例 ES6开始支持。 Promise

约定不等于承诺〃/ 2021年12月14日 07:13/ 0 赞/ 310 阅读