使用async如何进行并发处理？

@fruit-memory 对喔，用 lodash 来 map，用原生的也是可以啦

@Rukeith 你这是用了lodash?

我都这样写

await Promise.all(_.map(funs, () => new Promise(async (resolve, reject) => {
	try{
		resolve();
	} catch {
		reject();
	}
})));

transaction和promise.all可以搞定

@yuu2lee4 es2018？我去看看

用await Promise.all() 或者es2018 的 await for()

@fruit-memory

• forEach 实现不了 await
• for 循环 + await 并发为 1
• Promise.all + array.map 并发为 Infinity

酱

@magicdawn 这个好像跟那个foreach的差不多？每次产生一个新的async函数执行await

@lzghzr 懂了

use https://github.com/magicdawn/promise.map

const promise = pmap(array, async (item, index) => { /* blabla */ }, concurrency)

concurrency 就是并发

机制和 async.parallelLimit / bluebird Promise.map 一样的

@fruit-memory 因为forEach的参数是个函数

使用async关键字的函数实际上返回的是一个Promise对象

综合以上两点的话就不难理解await在for和forEach表现为什么不同了

所以使用forEach的话不是很好控制，await Promise.all()会等所有异步操作完成才会执行下一行代码，forEach则不会

@lzghzr foreach还有这种操作？

@fruit-memory 这样循环可以继续？

I‘m webapp-cnodejs-vue

阮一峰书里面好像有提到

I‘m webapp-cnodejs-vue

for循环中的await会影响下一次循环，也就是等一个await完成后才会执行下一个 如果需要并发可以使用forEach

忘说了，我用的数据库是MySQL，好像transaction用不上？

@linliny 我去看看😁

@XiaozhongLiu 前端有个批量操作，所以需要批量更新数据库

Transaction+Promise.all

循环update是什么需求？

为什么要循环去update, 代码放出来看看

我用sequelize的时候没找到多个数据的同时update的方法，sequelize好像是没有的。 自己用的是Transaction加for循环，如果有更好的解决办法，我也想知道。

跟单线程的串行和并行没啥区别吧

@XiaozhongLiu await的串行和并行有什么具体的区别吗？

多条 update 用 promise.all 包有啥问题么？

for里面的await是串行执行, 并不是并行

await在for循环中可以使用😄