为什么这个 myFunction().then() 操作似乎无限期挂起？

Question

我在处理一些非生产代码时遇到了一些问题。我想处理大约 3000 个数组元素。如果我 strace 节点进程，它位于epoll_wait(5，所以大概我阻塞了主线程。

任何人都可以建议a）我做错了什么或b）我如何查看执行堆栈/事件循环以准确检查代码为何挂起？我尝试调试并逐步执行代码并让该过程正常工作，但我并不明智。

使用 Promises.map 更新代码：

connection.query(firstPostQuery,{ x: whiteListString }, function( err, rows ) {

    Promise.map(rows, function(result) {


        return sfs.isSpammer({
            ip: result.ip,
            email: result.email,
            username: result.poster
        }).then(function(res) {
console.log(parseInt(res.username.appears) == 1); //evaluates to true

            if (parseInt(res.username.appears) == 1 ) {

                console.log(res.toJSON());
                fs.appendFile(__dirname + '/stopforumspam.txt', res.poster + '\n',
                    function(err) {
                        if (err) {
                            throw err;
                        }
                        return true;
                    });

            } else {
                fs.appendFile(__dirname + '/stopforumspam.txt',
                    'nope\n',
                    function(err) {
                        if (err) {
                            throw err;
                        }
                        return true;
                    });
            }
        });
        //Iteration completed
    }, {concurrency: 5}).then(function(result) {
        //Do something with result
        console.log(result);
    }).catch(function(err) {
        //Error
    });
});

我正在运行 node.js 4.2.4。我一直在尝试 Bluebird Promise，但不确定这在这种情况下是否有用，因为我还不完全理解 Promise。

Answer 1

您可以尝试使用 (bluebird) Promise.map 来迭代异步。

connection.query(firstPostQuery, {x: whiteListString}, function(err, rows) {

    Promise.map(rows, function(result, index) {
        console.log('item', index);
        return new Promise(function(resolve, reject) {
            sfs.isSpammer({
                ip: result.ip,
                email: result.email,
                username: result.poster
            }).then(function(res) {
                console.log('In Promise', res);
                console.log(parseInt(res.username.appears) == 1); //evaluates to
                                                                  // true
                if (res && parseInt(res.username.appears) == 1) {
                    return fs.appendFile(__dirname + '/stopforumspam.txt', res.poster + '\n',
                            function(err) {
                                console.log('In AppendFile spamer');
                                if (err) {
                                    reject(err);
                                }
                                resolve(true);
                            });
                } else {
                    return fs.appendFile(__dirname + '/stopforumspam.txt',
                            'nope\n',
                            function(err) {
                                console.log('In AppendFile good user');
                                if (err) {
                                    reject(err);
                                }
                                resolve(true);
                            });
                }
            });
        });
    }).then(function(res) {
        console.log(res);
    }).catch(function(err) {
        console.log(err);
    });
});