LOGO OA教程 ERP教程 模切知识交流 PMS教程 CRM教程 开发文档 其他文档  
 
网站管理员

JS异步任务的并行、串行,以及二者结合

freeflydom
2023年10月27日 17:41 本文热度 336

让多个异步任务按照我们的想法执行,是开发中常见的需求。今天我们就来捋一下,如何让多个异步任务并行,串行,以及并行串行相结合。

 

一、并行

并行是使用最多的方式,多个相互间没有依赖关系的异步任务,并行执行能够提高效率。

我们最经常用的,是Promise.all() 。


function f1() {    
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            console.log('1结束');
            resolve();
        }, 1000)
    });
}
function f2() {    
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            console.log('2结束');
            resolve();
        }, 900)
    });
}
function f3() {    
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            console.log('3结束');
            resolve();
        }, 800)
    });
}
let arr = [f1, f2, f3];
Promise.all(arr.map(i => i()));// 3结束// 2结束// 1结束

以下几种数组遍历方式,同样可以实现并行。


arr.forEach(item => (let i = 0; i < arr.length; i++arr.forEach(async item =>=>

相比之下,Promise.all()可以确保任务都执行成功,然后再执行后续操作,这是各种遍历无法做到的。

另外,还有一种方式也能实现并行:Promise.allSettled()。

Promise.allSettled(arr.map(i => i()));

这种方式很特别,它无法得到每个Promise对象的返回值,却可以精确得知每个任务的成功还是失败。如果你有这样的需求场景,用Promise.allSettled()就很合适。

 

二、串行

我在工作中遇到过一个场景,一个有1000+元素的数组,每个成员都是调用第三方接口的Promise对象。我像往常一样得意的使用Promise.all(),等着1000多个任务瞬间完成。然而,结果却让我大跌眼镜,这1000多个任务,只有一部分成功了,大部分都报错了。不管我执行几次,结果都是这个样。一筹莫展之后,我才从第三方那儿得知,他们的接口是有调用限制的,一个接口同一时间只能并行300个。

有没有办法能让它们一个接一个的执行呢?也就是串行。

nodejs koa框架的next()语法给了我启发,它就是让中间件一个接一个的执行。于是我想出了递归的方式:


async function serial(arr) {
    let item = arr.shift();
    await item();    
    if (arr.length > 0) {
        await serial(arr);
    }
}
serial(arr);// 1结束// 2结束// 3结束

其实,想让异步任务串行,不用这么麻烦。以下遍历的方式,同样可以实现串行。


// 使用for...of
async function f() {    
    for (let item of arr) {
        await item();
    }
}
f();// 使用for循环
async function f() {    
    for (let i = 0; i < arr.length; i++) {
        await arr[i]();
    }
}
f();

发现了没?为什么同样是for循环,同样是for...of,前面的写法是并行,后面就成了串行呢?

工作中,我们一定做过这样的尝试,想通过遍历,来让多个异步任务串行。但往往不得其法,怎么折腾它们都还是同时执行。

后一种写法,你可以理解为:await执行完成后,才会进入下一次循环。 其实,遍历,就相当于把每一个元素,在代码中从上到下写下来。当它们处于async函数中,并在每个元素前面加await,它们自然就能串行执行。否则,我们都知道,简单的从上到下写下来的异步任务,它们还是并行执行的。

好了,现在程序不报错了。但是,1000多个任务依次执行完成,足足花了十多分钟,太慢了!有没有办法,又快又不触发接口调用限制呢?

有,如果可以并行200个任务,完成后再开始下一轮200个......也就是,把并行和串行相结合。

 

三、并行串行结合


async function bingChuan(arr, num) {
    let items = arr.splice(0, num);
    
    await Promise.all(items.map(i => i()));    
    if (arr.length > 0) {
        await bingChuan(arr, num);
    }
}
bingChuan(arr, 2);// 2结束// 1结束// 3结束


查看原文


该文章在 2023/10/27 17:42:55 编辑过
关键字查询
相关文章
正在查询...
点晴ERP是一款针对中小制造业的专业生产管理软件系统,系统成熟度和易用性得到了国内大量中小企业的青睐。
点晴PMS码头管理系统主要针对港口码头集装箱与散货日常运作、调度、堆场、车队、财务费用、相关报表等业务管理,结合码头的业务特点,围绕调度、堆场作业而开发的。集技术的先进性、管理的有效性于一体,是物流码头及其他港口类企业的高效ERP管理信息系统。
点晴WMS仓储管理系统提供了货物产品管理,销售管理,采购管理,仓储管理,仓库管理,保质期管理,货位管理,库位管理,生产管理,WMS管理系统,标签打印,条形码,二维码管理,批号管理软件。
点晴免费OA是一款软件和通用服务都免费,不限功能、不限时间、不限用户的免费OA协同办公管理系统。
Copyright 2010-2024 ClickSun All Rights Reserved