我正在尝试使用新的异步特性，我希望解决我的问题能够在未来帮助到其他人。这是我正在工作的代码:
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函数中返回，匿名函数中的回调等。
setTimeout不是一个异步函数，所以你不能在ES7 async-await中使用它。但是你可以使用ES6 Promise实现你的睡眠功能:
function sleep (fn, par) {
return new Promise((resolve) => {
// wait 3s before calling fn(par)
setTimeout(() => resolve(fn(par)), 3000)
})
}
然后你就可以在ES7 async-await中使用这个新的睡眠函数了:
var fileList = await sleep(listFiles, nextPageToken)
请注意，我只是回答你关于将ES7 async/await与setTimeout结合的问题，尽管它可能无助于解决你每秒发送太多请求的问题。
更新:现代node.js版本有一个内置的异步超时实现，可以通过util访问。promisify助手:
const {promisify} = require('util');
const setTimeoutAsync = promisify(setTimeout);
您的睡眠函数不起作用，因为setTimeout没有(还没有?)返回一个可以等待的承诺。您将需要手动承诺:
function timeout(ms) {
return new Promise(resolve => setTimeout(resolve, ms));
}
async function sleep(fn, ...args) {
await timeout(3000);
return fn(...args);
}
顺便说一句，为了降低你的循环速度，你可能不想使用一个接受回调并像这样延迟它的睡眠函数。我建议:
while (goOn) {
// other code
var [parents] = await Promise.all([
listFiles(nextPageToken).then(requestParents),
timeout(5000)
]);
// other code
}
这使得父节点的计算至少需要5秒。
如果你想使用与setTimeout相同的语法，你可以写一个这样的helper函数:
const setAsyncTimeout = (cb, timeout = 0) => new Promise(resolve => {
setTimeout(() => {
cb();
resolve();
}, timeout);
});
然后你可以像这样调用它:
const doStuffAsync = async () => {
await setAsyncTimeout(() => {
// Do stuff
}, 1000);
await setAsyncTimeout(() => {
// Do more stuff
}, 500);
await setAsyncTimeout(() => {
// Do even more stuff
}, 2000);
};
doStuffAsync();
我做了一个主旨:https://gist.github.com/DaveBitter/f44889a2a52ad16b6a5129c39444bb57
我想指出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);
