如何使用 Promises 实现异步无限循环
How to have an async endless loop with Promises
我需要一个 "endless" while 循环,里面有 promises。下面是一些示例代码:
let noErrorsOccured = true
while (noErrorsOccured){
someAsyncFunction().then(() => {
doSomething();
}).catch((error) => {
console.log("Error: " + error);
noErrorsOccured = false;
});
}
function someAsyncFunction() {
return new Promise ((resolve, reject) => {
setTimeout(() => {
const exampleBool = doSomeCheckup();
if (exampleBool){
resolve();
} else {
reject("Checkup failed");
}
}, 3000);
});
}
所以这个while循环应该运行无穷无尽,除非发生错误,然后while循环应该停止。我怎样才能做到这一点?
希望您能理解我的意思,在此先感谢您。
How can I achieve this?
没有阻塞循环,因为 promises 将无法结算。您可以了解更多关于 JavaScript's event loop on MDN.
相反,在解决承诺时再次调用该函数:
Promise.resolve().then(function resolver() {
return someAsyncFunction()
.then(doSomething)
.then(resolver);
}).catch((error) => {
console.log("Error: " + error);
});
这就是我在 NodeJS 中的工作方式(基于此处的讨论:https://github.com/nodejs/node/issues/6673):
async function run(){
// Do some asynchronous stuff here, e.g.
await new Promise(resolve => setTimeout(resolve, 1000));
}
(function loop(){
Promise.resolve()
.then(async () => await run())
.catch(e => console.error(e))
.then(process.nextTick(loop));
})();
我需要一个 "endless" while 循环,里面有 promises。下面是一些示例代码:
let noErrorsOccured = true
while (noErrorsOccured){
someAsyncFunction().then(() => {
doSomething();
}).catch((error) => {
console.log("Error: " + error);
noErrorsOccured = false;
});
}
function someAsyncFunction() {
return new Promise ((resolve, reject) => {
setTimeout(() => {
const exampleBool = doSomeCheckup();
if (exampleBool){
resolve();
} else {
reject("Checkup failed");
}
}, 3000);
});
}
所以这个while循环应该运行无穷无尽,除非发生错误,然后while循环应该停止。我怎样才能做到这一点?
希望您能理解我的意思,在此先感谢您。
How can I achieve this?
没有阻塞循环,因为 promises 将无法结算。您可以了解更多关于 JavaScript's event loop on MDN.
相反,在解决承诺时再次调用该函数:
Promise.resolve().then(function resolver() {
return someAsyncFunction()
.then(doSomething)
.then(resolver);
}).catch((error) => {
console.log("Error: " + error);
});
这就是我在 NodeJS 中的工作方式(基于此处的讨论:https://github.com/nodejs/node/issues/6673):
async function run(){
// Do some asynchronous stuff here, e.g.
await new Promise(resolve => setTimeout(resolve, 1000));
}
(function loop(){
Promise.resolve()
.then(async () => await run())
.catch(e => console.error(e))
.then(process.nextTick(loop));
})();