在循环中使用 Promise

Question

我尝试创建一个加载测试脚本，但我遇到了奇怪的行为 我使用 https://github.com/prisma-labs/graphql-request 模块进行 graphql 请求。

但我没有看到进程运行到回调中

我看到了下一个结果。它停在前 5 个项目上。

GET:  MX
GET:  MX
GET:  DE
GET:  LT
GET:  US

我想我可能无法访问回调函数中的 requestCount 变量，但我什至看不到请求已发送。

import { request, gql } from 'graphql-request'

const MAX_REQUESTS = 5;
const countries = ['GB', 'UK', 'US', 'LT', 'IT', 'DE', 'MX']
const getRandomElement = (items) => {
    return items[Math.floor(Math.random()*items.length)];
}

let requestCount = 0;
while (true) {
    let country = getRandomElement(countries);
    let query = gql`
{
  country(code: "${country}") {
    name
    native
    capital
    emoji
    currency
    languages {
      code
      name
    }
  }
}`
    if (requestCount >= MAX_REQUESTS) {
        continue;
    }

    console.log('GET: ', country);

    request('https://countries.trevorblades.com/', query).then((data) => {
        console.log('OK: ', country);
        requestCount--;
    }).catch((error) => {
        console.log('FAILED: ', country);
        requestCount--;
        console.error(error)
    })

    requestCount++;
}

Answer 1

这是 Node.js 的行为（同步）

如果你有同步的 sn-p 并且里面有异步回调。它将等待同步执行，然后将移动到回调队列。

一个简单的例子

let counter = 0;
while(true) {
    console.log("While", counter++)
    setTimeout(() => {
        console.log("Inside Timeout")
    }, 0)
}

在您的用例中，您可以维护队列或更改条件

Answer 2

您的 while 循环永远不会中断，它会继续执行并占用线程。你的异步函数（Promises）永远没有机会回到线程执行。

编辑：每次发送一个包含 5 个项目的请求。

import { request, gql } from "graphql-request";

const MAX_REQUESTS = 5;
const arr = ["GB", "UK", "US", "LT", "IT", "DE", "MX"];

const getRandomElements = (items, numberOfElements) => {
  return Array.from({ length: numberOfElements }).map(
    _ => items[Math.floor(Math.random() * items.length)]
  );
};

const getQuery = country => gql`
    {
        country(code: "${country}") {
            name
            native
            capital
            emoji
            currency
            languages {
            code
            name
            }
        }
    }`;

(async function run() {
  while (true) {
    const countries = getRandomElements(arr, MAX_REQUESTS);
    const promises = countries.map(country =>
      request("https://countries.trevorblades.com/", getQuery(country))
    );
    const results = await Promises.allSettled(promises);

    results.forEach((res, i) => {
      if (res.status === "fulfilled") {
        console.log(`OK: Country:${countries[i]} data:${res.value}`);
      } else {
        console.log(`FAIL: Country:${countries[i]} Error:${res.reason}`);
      }
    });
  }
})();