设置间隔并等待特定条件

Question

我试图做的事情在节点js中可能是不可能的，但在我放弃之前，我想得到其他意见。

我有一个线程正在执行产品的设置。为了便于论证，让我们将其称为“主”线程。我希望在产品设置过程中可能发生的所有错误都被“主”线程捕获。如果安装成功，那么在我知道安装成功之前，我不希望“主”线程完成。

产品设置过程中的一个步骤涉及在客户的AWS帐户中创建CloudFormation堆栈。实现这一点的AWS函数是createStack。此函数仅启动创建堆栈的过程。如果使用await调用此函数，那么在获得返回值后，创建堆栈的过程仍将运行。

还有一个AWS CloudFormation函数叫做DescribeBacks，我可以用它来了解创建过程。我不能重复调用这个方法（在调用之间不使用较大的间隔），因为AWS限制了我调用方法的频率。

我希望能够每分钟调用此函数一次，以检查堆栈创建的进度，直到我可以确定安装是否成功。但至关重要的是，我还希望“主”线程等到这一成功或失败发生。

这在节点js中可能吗？我是节点js的新手。请随时告诉我，我误用了它，并且我以错误的方式思考问题。我怀疑我是。

解决方案：这是为我解决问题的代码。多亏了Tomalak

function checkStackCreationProgress(params) {
    return new Promise( (resolve, reject) => {
        const intervalId = setInterval( async () => {
            try {
                const result = await checkProgress(params);

                switch(result.status) {
                    case 'IN_PROGRESS': break; //do nothing
                    case 'COMPLETE': clearInterval(intervalId); resolve(result); break;
                    case 'FAILED': clearInterval(intervalId); reject(result); break;
                }
            }
            catch(error) {
                clearInterval(intervalId);
                reject(error);
            }
        },
        60000);
    })
    .then( () => {
        return;
    })
    .catch(error => {
        throw new SetupFailedError(`Failed to create ...`, error);
    });
}

在安装成功完成或失败之前，此函数不会返回

Answer 1

如果使用await调用此函数，那么在获得返回值后，创建堆栈的过程仍将运行。

不要用wait调用它，这会阻塞线程。

异步函数返回promise，您可以链接它们，同时做其他事情。

因此

try {
    var result = await createStack({some: params));
    // work with result
} catch (ex) {
    // handle error
}

做

createStack({some: params)).then(function (result) {
    // work with result
}).catch(function (error) {
    // handle error
});

第二种形式是非阻塞的，你可以同时做任何工作。例如：

var checking = setInterval(function () {
    // check/output for the stack status...
}, 60000)

createStack({some: params)).then(function (result) {
    clearInterval(checking);

    // work with result
}).catch(function (error) {
    clearInterval(checking);

    // handle error
});

console.log("Stack is being created, hang on...");