提问者:小点点

异步函数+await+setTimeout组合


我正在尝试使用新的异步特性,我希望解决我的问题能在将来帮助其他人。这是我正在工作的代码:

  async function asyncGenerator() {
    // other code
    while (goOn) {
      // other code
      var fileList = await listFiles(nextPageToken);
      var parents = await requestParents(fileList);
      // other code
    }
    // other code
  }

  function listFiles(token) {
    return gapi.client.drive.files.list({
      'maxResults': sizeResults,
      'pageToken': token,
      'q': query
    });
  }

问题是,我的while循环运行得太快,脚本每秒向google API发送的请求太多。因此,我想建立一个睡眠功能,延迟的请求。因此,我也可以使用这个函数来延迟其他请求。如果有其他方法可以延迟请求,请告诉我。

不管怎么说,这是我的新代码,它不起作用。请求的响应返回到setTimeout内的匿名异步函数,但是我不知道如何将响应返回到sleep函数。到初始的asyncGenerator函数。

  async function asyncGenerator() {
    // other code
    while (goOn) {
      // other code
      var fileList = await sleep(listFiles, nextPageToken);
      var parents = await requestParents(fileList);
      // other code
    }
    // other code
  }

  function listFiles(token) {
    return gapi.client.drive.files.list({
      'maxResults': sizeResults,
      'pageToken': token,
      'q': query
    });
  }

  async function sleep(fn, par) {
    return await setTimeout(async function() {
      await fn(par);
    }, 3000, fn, par);
  }

我已经尝试了一些选项:将响应存储在全局变量中并从sleep函数返回,在匿名函数内回调等等。


共3个答案

匿名用户

您的sleep函数不工作,因为settimeout不工作(还?)返回一个可以是Awaited的承诺。您将需要手动允诺它:

function timeout(ms) {
    return new Promise(resolve => setTimeout(resolve, ms));
}
async function sleep(fn, ...args) {
    await timeout(3000);
    return fn(...args);
}

顺便说一句,为了降低循环的速度,您可能不想使用sleep函数,该函数接受回调并像这样延迟回调。我更想建议你做一些像这样的事

while (goOn) {
  // other code
  var [parents] = await Promise.all([
      listFiles(nextPageToken).then(requestParents),
      timeout(5000)
  ]);
  // other code
}

这使得父级的计算至少需要5秒。

匿名用户

从节点7.6开始,您可以将utils模块中的函数promisifysetTimeout()组合在一起。

const sleep = require('util').promisify(setTimeout)
const sleep = m => new Promise(r => setTimeout(r, m))
(async () => {
    console.time("Slept for")
    await sleep(3000)
    console.timeEnd("Slept for")
})()

匿名用户

快速的单行,内联方式

 await new Promise(resolve => setTimeout(resolve, 1000));

相关问题