使用 async/await 进行续集查询的无限循环

Posted 2023-03-07

【中文标题】使用 async/await 进行续集查询的无限循环

【英文标题】：Infinite Loop for sequelize-query with async/await

【发布时间】：2020-09-26 19:36:26

【问题描述】：

我想调用一个函数，其中包含一个无限循环中的 sequelize 查询（返回一个订单），这意味着在解决该函数时再次调用该函数，因此始终搜索新订单。

我原来的做法是

do 
    (async function () 
        var nextOrder = await getNextOrder()
        console.log("nextOrder",nextOrder)
    )(); 
 while (ENV == "development");

这是在召唤：

function getNextOrder() 
    return new Promise(async (resolve, reject) => 
        try 
            Orders.findOne(
                where: 
                    type: 
                        [Op.or]: ["buy", "sell"]
                    ,
                ,
            ).then(async nextOrder => 
                // Doing stuff with next order
                return resolve()
            ).catch(function (e) 
                console.log("error", e)
                return reject(e)
            )
         catch (e) 
            console.log("error", e)
            return reject(e)
        
    )

上述方法的问题在于，函数：getNextOrder 永远不会解析，而 while 循环只会永久调用它。通过一次又一次地调用相同的函数，但在它解决之后，需要做什么才能使上述代码正常工作？

现在我最终采用了以下方法，它正在工作，但让上面的 async/await 方法工作会很有趣。

getNextOrder()

这是在召唤：

function getNextOrder() 
    Orders.findOne(
        where: 
            type: 
                [Op.or]: ["buy", "sell"]
            ,
        ,
    ).then(async nextOrder => 
        // Doing stuff with next order
    ).then(function() 
        getNextOrder() // <------ Calling function again here
        return
    ).catch(function (e) 
        console.log("error", e)
        return
    )

【参考方案1】：

您不应在 new Promise(async (resolve, reject) 代码段中使用 async 或在函数内使用 async/await：

function getNextOrder() 
    return new Promise(async (resolve, reject) => 
        try 
            const nextOrder = await Orders.findOne(
                where: 
                    type: 
                        [Op.or]: ["buy", "sell"]
                    ,
                ,
            )
            // Doing stuff with next order
            return resolve()
         catch (e) 
            console.log("error", e)
            return reject(e)
        
    )