异步函数 + await + setTimeout 的组合
Combination of async function + 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 发送了太多请求。因此我想建立一个延迟请求的睡眠功能。因此我也可以使用这个函数来延迟其他请求。如果有其他延迟请求的方法,请告诉我。
无论如何,这是我的新代码,它不起作用。请求的响应 returned 到 setTimeout 中的匿名异步函数,但我只是不知道如何 return 响应睡眠函数 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);
}
我已经尝试了一些选项:将响应存储在一个全局变量中,return它来自睡眠函数,匿名函数中的回调等。
setTimeout
不是 async
函数,所以你不能将它与 ES7 async-await 一起使用。但是您可以使用 ES6 Promise:
实现 sleep
函数
function sleep (fn, par) {
return new Promise((resolve) => {
// wait 3s before calling fn(par)
setTimeout(() => resolve(fn(par)), 3000)
})
}
然后你就可以在 ES7 async-await 中使用这个新的 sleep
函数了:
var fileList = await sleep(listFiles, nextPageToken)
请注意,我只是在回答你关于结合 ES7 async/await 和 setTimeout
的问题,尽管它可能无助于解决你的问题每秒发送太多请求。
更新: 现代 node.js 版本具有内置异步超时实现,可通过 util.promisify 帮助程序访问:
const {promisify} = require('util');
const setTimeoutAsync = promisify(setTimeout);
您的 sleep
函数不起作用,因为 setTimeout
还没有(还?)return 一个可以 await
编辑的承诺。您将需要手动对其进行承诺:
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
}
这使得 parents
的计算至少需要 5 秒。
从 Node 7.6 开始,您可以将 utils 模块中的 promisify
函数与 setTimeout()
组合起来。
Node.js
const sleep = require('util').promisify(setTimeout)
Javascript
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));
如果您想使用与 setTimeout
相同的语法,您可以编写如下辅助函数:
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
以下代码适用于 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..."
的语法错误
这是一种更快的单行修复。
希望这会有所帮助。
// WAIT FOR 200 MILISECONDS TO GET DATA //
await setTimeout(()=>{}, 200);
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
根据 Dave's
制作了一个实用程序
基本上是传入一个done
回调,在操作完成时调用。
// Function to timeout if a request is taking too long
const setAsyncTimeout = (cb, timeout = 0) => new Promise((resolve, reject) => {
cb(resolve);
setTimeout(() => reject('Request is taking too long to response'), timeout);
});
我是这样使用的:
try {
await setAsyncTimeout(async done => {
const requestOne = await someService.post(configs);
const requestTwo = await someService.get(configs);
const requestThree = await someService.post(configs);
done();
}, 5000); // 5 seconds max for this set of operations
}
catch (err) {
console.error('[Timeout] Unable to complete the operation.', err);
}
这是我现在在 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)
...
}
await setTimeout(()=>{}, 200);
如果您的 Node 版本为 15 及以上,则可以使用。
定时器承诺 API
await setTimeout
终于到了 Node.js 16,不再需要使用 util.promisify()
:
import { setTimeout } from 'timers/promises';
(async () => {
const result = await setTimeout(2000, 'resolved')
// Executed after 2 seconds
console.log(result); // "resolved"
})()
官方 Node.js 文档:Timers Promises API(已在 Node 中构建的库)
await new Promise(resolve => setTimeout(() => { resolve({ data: 'your return data'}) }, 1000))
如何一次性记录所有回复?
async function sayHello(name) {
let greet = `Hey! ${name} very nice to meet you bud.`;
setTimeout(() => {
return {
greet,
createdAt: new Date(),
};
}, 1000);
}
const response1 = async () => await sayHello("sounish");
const response2 = async () => await sayHello("alex");
const response3 = async () => await sayHello("bill");
async function getData() {
const data1 = await sayHello("sounish");
const data2 = await sayHello("alex");
const data3 = await sayHello("bill");
return { data1, data2, data3 };
}
Promise.all([sayHello("sounish"), sayHello("alex"), sayHello("bill")]).then(
(allResponses) => {
console.log({ allResponses });
}
);
getData().then((allData) => {
console.log({ allData });
});
我将此代码片段留给想要使用 setTimeout
获取 API 调用(例如获取客户)的人:
const { data } = await new Promise(resolve => setTimeout(resolve, 250)).then(() => getClientsService())
setName(data.name || '')
setEmail(data.email || '')
我正在尝试使用新的异步功能,希望解决我的问题对以后的其他人有所帮助。这是我正在运行的代码:
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 发送了太多请求。因此我想建立一个延迟请求的睡眠功能。因此我也可以使用这个函数来延迟其他请求。如果有其他延迟请求的方法,请告诉我。
无论如何,这是我的新代码,它不起作用。请求的响应 returned 到 setTimeout 中的匿名异步函数,但我只是不知道如何 return 响应睡眠函数 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);
}
我已经尝试了一些选项:将响应存储在一个全局变量中,return它来自睡眠函数,匿名函数中的回调等。
setTimeout
不是 async
函数,所以你不能将它与 ES7 async-await 一起使用。但是您可以使用 ES6 Promise:
sleep
函数
function sleep (fn, par) {
return new Promise((resolve) => {
// wait 3s before calling fn(par)
setTimeout(() => resolve(fn(par)), 3000)
})
}
然后你就可以在 ES7 async-await 中使用这个新的 sleep
函数了:
var fileList = await sleep(listFiles, nextPageToken)
请注意,我只是在回答你关于结合 ES7 async/await 和 setTimeout
的问题,尽管它可能无助于解决你的问题每秒发送太多请求。
更新: 现代 node.js 版本具有内置异步超时实现,可通过 util.promisify 帮助程序访问:
const {promisify} = require('util');
const setTimeoutAsync = promisify(setTimeout);
您的 sleep
函数不起作用,因为 setTimeout
还没有(还?)return 一个可以 await
编辑的承诺。您将需要手动对其进行承诺:
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
}
这使得 parents
的计算至少需要 5 秒。
从 Node 7.6 开始,您可以将 utils 模块中的 promisify
函数与 setTimeout()
组合起来。
Node.js
const sleep = require('util').promisify(setTimeout)
Javascript
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));
如果您想使用与 setTimeout
相同的语法,您可以编写如下辅助函数:
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
以下代码适用于 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..."
这是一种更快的单行修复。
希望这会有所帮助。
// WAIT FOR 200 MILISECONDS TO GET DATA //
await setTimeout(()=>{}, 200);
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
根据 Dave's
基本上是传入一个done
回调,在操作完成时调用。
// Function to timeout if a request is taking too long
const setAsyncTimeout = (cb, timeout = 0) => new Promise((resolve, reject) => {
cb(resolve);
setTimeout(() => reject('Request is taking too long to response'), timeout);
});
我是这样使用的:
try {
await setAsyncTimeout(async done => {
const requestOne = await someService.post(configs);
const requestTwo = await someService.get(configs);
const requestThree = await someService.post(configs);
done();
}, 5000); // 5 seconds max for this set of operations
}
catch (err) {
console.error('[Timeout] Unable to complete the operation.', err);
}
这是我现在在 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)
...
}
await setTimeout(()=>{}, 200);
如果您的 Node 版本为 15 及以上,则可以使用。
定时器承诺 API
await setTimeout
终于到了 Node.js 16,不再需要使用 util.promisify()
:
import { setTimeout } from 'timers/promises';
(async () => {
const result = await setTimeout(2000, 'resolved')
// Executed after 2 seconds
console.log(result); // "resolved"
})()
官方 Node.js 文档:Timers Promises API(已在 Node 中构建的库)
await new Promise(resolve => setTimeout(() => { resolve({ data: 'your return data'}) }, 1000))
如何一次性记录所有回复?
async function sayHello(name) {
let greet = `Hey! ${name} very nice to meet you bud.`;
setTimeout(() => {
return {
greet,
createdAt: new Date(),
};
}, 1000);
}
const response1 = async () => await sayHello("sounish");
const response2 = async () => await sayHello("alex");
const response3 = async () => await sayHello("bill");
async function getData() {
const data1 = await sayHello("sounish");
const data2 = await sayHello("alex");
const data3 = await sayHello("bill");
return { data1, data2, data3 };
}
Promise.all([sayHello("sounish"), sayHello("alex"), sayHello("bill")]).then(
(allResponses) => {
console.log({ allResponses });
}
);
getData().then((allData) => {
console.log({ allData });
});
我将此代码片段留给想要使用 setTimeout
获取 API 调用(例如获取客户)的人:
const { data } = await new Promise(resolve => setTimeout(resolve, 250)).then(() => getClientsService())
setName(data.name || '')
setEmail(data.email || '')