javascript - for 循环事件驱动代码？

Question

在 Redis 数据存储中，我有一个键列表，我想迭代该键列表并从 Redis 获取这些值。问题是我正在使用事件驱动语言，即通过 node.js 的 javascript

如果 javascript 是程序化的，我可以这样做

function getAll(callback) {
    var list = redis.lrange(lrange('mykey', 0, -1);
    for ( var i = 0; i < list.length; i+= 1 ) {
        list[i] = redis.hgetall(list[i]);
    }
    callback(list);
}

但是，我不能，因此..我这样做？

function getAll(callback) {
    redis.lrange('mykey', 0, -1, function(err, reply) {
        // convert reply into messages
        var list = [];
        var index = -1;
        var recurse = function() {
            if ( index == reply.length ) {
                callback(list);
            } else {
                redis.hgetall(reply[i], function(err, reply) {
                    list.push(reply);
                    index += 1;
                    recurse();
                });
            }
        };
        recurse()
    });
};

这似乎是错误的，因为我不是立即执行所有请求，然后让回调插入到列表中，而是强制执行顺序调用序列。如果有 1000 个 key 会发生什么？

我可以怎样做吗？

function getAll(callback) {
    redis.lrange('mykey', 0, -1, function(err, reply) {

        // convert reply into messages
        var list = [];
        var insert = function(err, reply) {
            list.push(reply);
        };
        for ( var i = 0; i < reply.length; i += 1 ) {
            redis.hgetall(reply[i], insert);
        }

        ??? how to block until finished ??? 
        callback(list);
    });
};

Answer 1

??? how to block until finished ???

如果您进行的调用是异步的，则不能。您必须定义您的 getAll 并期望它将异步完成，然后对其进行一些重新调整。

我不熟悉您正在进行的 redis 调用，但基本模式是:

function doTheBigThing(param, callbackWhenDone) {
    asyncCallToGetList(param, function(result) {
        var list = [];

        asyncCallToGetNextEntry(result.thingy, receivedNextEntry);

        function receivedNextEntry(nextResult) {
            if (nextResult.meansWeAreDone) {
                callback(list);
            }
            else {
                list.push(nextResult.info);
                asyncCallToGetNextEntry(result.thingy, receivedNextEntry);
            }
        }
    });
}

分解:

1. doBigThing(您的getAll)被调用。
2. 它执行“获取列表”调用，传入函数以在我们拥有列表或列表句柄或其他内容时用作回调。
3. 该回调定义了一个函数 receivedNextEntry，并使用用于检索条目的任何信息调用“获取下一个条目”函数，并将其作为回调传入。
4. receivedNextEntry 存储它获得的条目，如果完成，则触发主“全部完成”回调；如果没有，则发出下一个请求。

很抱歉无法为您提供特定于 Redis 的答案，但我认为映射是:

• doBigThing = getAll
• asyncCallToGetList = redis.lrange
• asyncCallToGetNextEntry = redis.hgetall

...但是您使用 redis.lrange 和 redis.hgetall 的参数恐怕我不知道。