JavaScript 中的异步并发

2022-11-03 18:50:54 阅读：307 来源： 互联网

我最近的任务是构建一个微服务，该服务需要发出数千个HTTP请求并处理响应。为了创建这种情况的简单模拟，我将使用一个 fake 函数，该函数接受任意值并返回解析为包含值和间隔的对象：requestPromise

const {promisify} = require('util')
const sleep = promisify(setTimeout)const request = async(data) => {
  let time = Math.random() * 1000
  await sleep(time)
  return {data, time}
}

我有一堆包含请求参数数据的记录，所以我做的第一件事就是查询这些记录。对于此示例，我们将使用整数数组来模拟记录。我的第一直觉（我经验不足）是遍历记录数组，发出每个HTTP请求并将结果推送到新数组：

async function main() {
  const records = Array.from(new Array(10)).map((e, i) => i)
  let responses = []
  console.time('Inline')
  for (let i = 0; i < records.length; i++) {
    let response = await request(records[i])
    responses.push(response)
  }
  console.log(JSON.stringify(responses, null, 2))
  console.timeEnd('Inline')
}

这工作正常，但我们必须在发出下一个请求之前等待每个响应，这意味着这可能需要长达 10 秒才能执行。结果如下所示：

[
  {     
    "data": 0,
    "time": 48.95140139293264
  },
  {
    "data": 1,
    "time": 351.42969859007377
  },
  ...
]
Inline: 5210.4460449ms

5秒是一段很长的时间。现在让我们看看如何同时执行这些请求。我们可以将每个调用推送到一个数组中，并使用 Promise.all（）等待它们全部解析：request

async function main() {
  const records = Array.from(new Array(10)).map((e, i) => i)
  console.time('Concurrent')
  let promises = []
  for (let i = 0; i < records.length; i++) {
    promises.push(request(records[i]))
  }
  let responses = await Promise.all(promises)
  console.log(JSON.stringify(responses, null, 2))
  console.timeEnd('Concurrent')
}

瞧，我们刚刚加快了服务速度！结果如下所示：records.length

[
  {
    "data": 0,
    "time": 160.08417354131944
  },
  {
    "data": 1,
    "time": 560.08495847237463
  },
  ...,
  {
    "data": 9,
    "time": 223.39482395749209
  }
]
Concurrent: 560.08495847237463ms

使用这种非阻塞方法会在所有承诺全部完成后立即获取它们的结果，因此总执行时间仅比最慢的 HTTP 请求大几毫秒。此相同技术可用于任何异步操作集合。responses

只是为了好玩，让我们在一行中使用Array.map:

let responses = await Promise.all(records.map(record => request(record)))

我希望这有帮助，快乐编码。

标签：javaJDK,java,虚拟机,布局,数据,代码,程序,面试,题目
来源：

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

JavaScript 中的异步并发