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

  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循环运行得太快,脚本每秒向谷歌API发送太多请求。因此,我想建立一个睡眠函数延迟请求。因此,我还可以使用这个函数来延迟其他请求。如果有其他方法可以延迟请求,请让我知道。

不管怎样,这是我的新代码,它不能工作。请求的响应被返回到setTimeout内的匿名异步函数,但我只是不知道如何将响应返回到睡眠函数resp。初始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函数中返回,匿名函数中的回调等。


当前回答

下面的代码可以在Chrome和Firefox以及其他浏览器中运行。

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

但是在Internet Explorer中,我得到了一个语法错误的“(resolve **=>** setTimeout…”

其他回答

这是我2020年在AWS labdas中使用nodejs的版本

const sleep = require('util').promisify(setTimeout)

async function f1 (some){
...
}

async function f2 (thing){
...
}

module.exports.someFunction = async event => {
    ...
    await f1(some)
    await sleep(5000)
    await f2(thing)
    ...
}

这是在一行程序中快速修复的方法。

希望这能有所帮助。

// WAIT FOR 200 MILISECONDS TO GET DATA //
await setTimeout(()=>{}, 200);

我想指出Promise.all的一个强大扩展。一个相当优雅的解决方案是让一个promise只有时间限制(例如new promise ((resolve) => setTimeout(resolve, timeout)))。

await new Promise.race([myPromise, timeoutPromise])

一旦一个承诺完成,就会继续。myPromise可以在内部等待不同的超时,或者简单地使用Promise.all

const timeout = ms => new Promise((resolve) => setTimeout(resolve, ms));
await Promise.race([
    Promise.all([myPromise, timeout(500)]),
    timeout(5000)
]);

结果是异步调用的运行频率不会超过每秒两次,在出现某些(网络/服务器?)错误时,超时时间为5秒。

此外,您可以使这个非常通用和可定制的函数如下:

function callWithTimeout(promise, msTimeout=5000, throws=false) {
    const timeout = ms => new Promise((resolve, reject) =>
        setTimeout(throws ? reject : resolve, ms));
    await Promise.race([
        //depends whether you want to wait there or just pass the promise itself
        Promise.all([promise, timeout(500)]), 
        timeout(msTimeout)
    ]);
}
    

它最终允许您自定义超时时间以及承诺是否应该成功或在超时时抛出。拥有这样健壮的通用实现可以在将来为您省去很多麻烦。你也可以在抛出时设置一个字符串而不是布尔值,并将这个变量绑定到用于自定义错误消息的reject: reject。bind(未定义,抛出)

注意,你不应该守口如瓶。

const myPromise = async x => x;
//will never time out and not because myPromise will finish immediatelly
callWithTimeout(await myPromise(), 200, true); 
//will possibly timeout after 200 ms with an exception 
callWithTimeout(myPromise(), 200, true); 
var testAwait = function () {
    var promise = new Promise((resolve, reject) => {
        setTimeout(() => {
            resolve('Inside test await');
        }, 1000);
    });
    return promise;
}

var asyncFunction = async function() {
    await testAwait().then((data) => {
        console.log(data);
    })
    return 'hello asyncFunction';
}

asyncFunction().then((data) => {
    console.log(data);
});

//Inside test await
//hello asyncFunction
await setTimeout(()=>{}, 200);

如果您的Node版本是15及以上,将正常工作。