在 Array.filter 中正确使用 Async
本文译自How to use async functions with Array.filter in Javascript - Tamás Sallai。
0. 如何仅保留满足异步条件的元素
在第一篇文章中,我们介绍了 async / await 如何帮助处理异步事件,但在异步处理集合时却无济于事。在本文中,我们将研究该filter
函数,它可能是支持异步函数的最直观的方法。
1. Array.filter
该filter
函数仅保留通过条件的元素。它得到一个断言( predicate )函数,并且此函数返回 true / false 值。结果集合仅包含断言( predicate )返回 true 的元素。
const arr = [1, 2, 3, 4, 5];
const syncRes = arr.filter((i) => {
return i % 2 === 0;
});
console.log(syncRes);
// 2,4
2. filter 结合 map 使用
这次的异步版本要复杂一些,它分为两个阶段。第一个通过断言函数异步地映射数组,从而生成true / false 值。然后第二步是利用第一步的结果同步 filter
const arr = [1, 2, 3, 4, 5];
const asyncFilter = async (arr, predicate) => {
const results = await Promise.all(arr.map(predicate));
return arr.filter((_v, index) => results[index]);
}
const asyncRes = await asyncFilter(arr, async (i) => {
await sleep(10);
return i % 2 === 0;
});
console.log(asyncRes);
// 2,4
或单行实现:
const asyncFilter = async (arr, predicate) => Promise.all(arr.map(predicate))
.then((results) => arr.filter((_v, index) => results[index]));
并发
上面的实现同时运行所有断言函数。通常,这很好,但是与所有其他功能一样,它可能会使某些资源变得过分紧张。幸运的是,由于上述实现依赖于此map
,因此可以使用相同的并发控件。
4. filter 结合 reduce 使用
除了使用异步map
与同步之外filter
,异步reduce
也可以完成这项工作。由于它只是一个功能,因此即使没有提供相同级别的控制,结构也更加容易。
首先,从一个空数组([]
)开始。然后通过断言函数运行下一个元素,如果通过则将其追加到数组。如果没有,请跳过它。
// concurrently
const asyncFilter = async (arr, predicate) =>
arr.reduce(async (memo, e) =>
await predicate(e) ? [...await memo, e] : memo
, []);
请注意,await predicate(e)
在 await memo
之前,这意味着这些将并行调用。
顺序处理
要在调用下一个谓词函数之前等待其结束,请更改await
的顺序:
// sequentially
const asyncFilter = async (arr, predicate) =>
arr.reduce(async (memo, e) =>
[...await memo, ...await predicate(e) ? [e] : []]
, []);
此实现等待上一个元素,然后根据断言(...[e]
或...[]
)的结果有条件地附加一个元素。
5. 结论
虽然异步filter
是可能的,但它最初的工作方式看起来很奇怪。尽管并发控制仍然可用,但与其他异步功能相比,它们需要更多的计划去控制它。
推荐阅读
最新文章
- jQuery中的100个技巧
- SQL 语句格式
- 【基础知识】.Net基础加强08天
- [每日一题] OCP1z0-047 :2013-08-26 TIMESTAMP WITH LOCAL TIME ZONE....................112
- SQL Prompt 5.3.4.1
- x264命令参数与代码中变量的对应关系
- C# 墙纸更换程序
- 【待修改】nyoj 38 最小生成树
- Bomb Game
- jquery.ajax和Ajax 获取数据
- 如何在 静态编译的QT 5.5.1 中 使用数据库插件连接 ODBC(调用静态插件)
- JEECMS用法总结
- hdu1690 Bus System (dijkstra)
- #define命令的一些高级用法
- Win 及 Linux 查找mac地址的方法
- zigbee 安全通信加密链接密钥
- 第13课 lambda表达式
- Oracle的SQL语句中如何处理‘&;’符号
- hdu 4927 组合+公式
- 从 Azure 下载 Windows VHD
热门文章
- python的基本数据类型简介
- C++结构体和类的区别总结及各自优缺点
- isEmpty 判空函数 内部分别判断是 null 空数组 等
- 关于WPF System.windows.Media.FontFamily 的类型初始值设定项引发异常问题解决方法
- java之AQS和显式锁
- 【盘它!】那些让效率MAX的工具和方法(Mac篇)
- 一道值得思考的fork()面试题
- Caused by: java.lang.IllegalArgumentException
- Spring框架——IOC 工厂方法
- snmap弱口令攻击利用