如何与 forEach 同时执行承诺？

Question

我有一个代码可以在我的系统中更新或创建新用户。它与 forEach 函数一起使用，效果很好。 但是，我想利用 Node.js 并同时执行多个更新/创建。 我试图创建一系列承诺，但我认为我构建的承诺是错误的。 这是可以正常工作的代码：

import usersjson from './jsons/users.json';
if (usersjson.users.length) {
    for (const user of usersjson.users) {
        let getuser = getUser(url, user.Id, 'Id');
            getuser.then((data) => {//Make a call to get user by id
                if (data.users.length != 0) { //If user exists
                    let update = updateUser(url, user, data.users[0].id);//update user function
                    update.then((updateresponse) => {
                        console.log(updateresponse);
                        }).catch((err) => {
                            console.log(err);
                        })
                } else { //if user doesn't exist
                    let update = newUser(url, user);//createUser(settings.fieldMap, user)
                    update.then((response) => {
                        console.log(response);
                    }).catch((err) => {
                        console.log(err);
                    });
                }
            }) 
    };
};

现在，我想将“更新”变成 Promise，这样我就可以使用 Promise.all() 同时发送多个。这是我尝试过的：

import usersjson from './jsons/users.json';
let promises = [];
if (usersjson.users.length) {
    for (const user of usersjson.users) {
        if (promises.length <= 20) {
            let getuser = getUser(url, user.Id, 'Id');
            getuser.then((data) => {//Make a call to get user by id
                if (data.users.length != 0) { //If user exists
                    let update = new promise ((resolve, reject) => {
                        updateUser(url, user, data.users[0].id).then((response) => {
                            resolve(response);
                        }).catch((err) => {
                            console.log(err)
                        });
                    });
                    promises.push(update);
                } else { //if user doesn't exist
                    let update = new promise ((resolve, reject) => {
                        newUser(url, user).then((response) => {
                            resolve(response);
                        }).catch((err) => {
                            console.log(err);
                        })
                    });
                    psomises.push(update);
                }
            });
        } else {
            await promises.all(update)
            .then ((result) => {
                console.log(result);
                promises = [];
            }).catch(err){
                console.log(err);
            }
        };
    };
};

但我收到一条错误消息：

(node:22016) UnhandledPromiseRejectionWarning: ReferenceError: promise 没有定义 在文件：///C:/xampp/htdocs/NodeAPI/server.js:70:21 在 processTicksAndRejections (internal/process/task_queues.js:97:5) (node:22016) UnhandledPromiseRejectionWarning：未处理的承诺拒绝。这 错误源于在异步函数内部抛出 没有 catch 块，或拒绝未处理的承诺 使用 .catch()。在未处理的承诺上终止节点进程 拒绝，请使用 CLI 标志 --unhandled-rejections=strict（请参阅 https://nodejs.org/api/cli.html#cli_unhandled_rejections_mode)。 （拒绝 ID：1）（节点：22016）[DEP0018] 弃用警告：未处理 不推荐使用承诺拒绝。在未来，承诺拒绝 未处理的将终止 Node.js 进程 非零退出代码。

我的问题是，如何让数组中的 20 个用户同时运行 forEach，而不是一个一个地运行？

Answer 1

1. 首先，将处理每个单独的user 值的代码流 移到它自己单独的async 函数中。

   • 由于 async 函数的实际工作方式（因为每个 async function 标记每个异步状态机的边界），在 for 语句中执行并发异步工作实际上并不可行。

2. 从for 循环中调用该函数。

3. 总是更喜欢=== 而不是==。

4. 使用 TypeScript。在没有 TypeScript 的情况下使用 async JavaScript 是一个痛苦的世界，因为您需要跟踪哪些函数返回 Promise<T> 与那些不返回的函数，以及正确解包 Promise<T> 对象。

5. 始终尽可能拥有自己的 try/catch 语句来包装 async 函数的整个主体，否则您将不得不处理不同 JS 引擎和 JS 代码如何处理抛出的异常和对象的不一致。

import usersjson from './jsons/users.json';

async function updateUsers() {
    
    const promises = [];

    const users = usersjson;
    for( const user of users ) {
        const promise = updateUser( user ); // <-- Note this is *NOT* awaited here.
        promises.push( promise );
    }

    await Promise.all( promises ); // <-- This is where we await everything.
}

async function updateUser( user ) {
    
    try {
        const data = await getUser( url, user.Id, 'Id' );
        if( data.users.length === 0 ) {
            let createResult = await newUser( url, user );
            console.log( "Created new user %o", createResult  );
        }
        else {
            const updateResult = await updateUser( url, user, data.users[0].id );
            console.log( "Update user %o: Result: %o", user.Id, updateResult );
        }
    }
    catch( err ) {
        console.error( "Failed to update (or create) user with UserId %o: %o", user.userId, err );
    }
}

Answer 2

实现这一点的最简单方法是在 foarch 方法中，将所有的 Promise 引入一个数组中，然后调用它们，然后使用 Promise.all 等到一切都完成。

let promiseArray = []
array.forEach(x => {
      // Do whatever you need
     promiseArray.push(updateUser(...))
     // Push only the promise without the 'then'
     // You are going to handle the response or 
     // the errors later  

})
const promiseResponses = await Promise.all(promiseArry)
// promiseResponses is an array of responses
// like promiseResponse[0]