javascript - Meteor.wrapAsync 导致 Meteor 无响应

Question

我正在使用 Meteor._wrapAsync 强制只调用一次函数 writeMeLater 任意时刻执行。如果在 1 秒内对 writeMeLater 进行了 10 次调用，则其他 9 次调用应按顺序排队。

要检查 writeMeLater 是否同步运行，Logs 集合中的 timestamp 字段应间隔 1 秒。

问题:使用下面的代码，只有第一个调用writeMeLater被执行，其他9个似乎没有运行。为什么会这样？

服务器代码:

writeMeLater = function(data) {
    console.log('writeMeLater: ', data)

    // simulate taking 1 second to complete
    Meteor.setTimeout(function() {
        Logs.insert({data: data, timestamp: new Date().getTime()})
    }, 1 * 1000)
}

writeMeLaterSync = Meteor._wrapAsync(writeMeLater)


// simulate calling the function many times real quick
for(var i=0; i<10; i++) {
    console.log('Loop: ', i)
    writeMeLaterSync(i)
}

输出:

=> Meteor server running on: http://localhost:4000/
I20140119-11:04:17.300(8)? Loop:  0
I20140119-11:04:17.394(8)? writeMeLater:  0

---

使用 writeMeLater 的替代版本，我遇到了同样的问题:

writeMeLater = function(data) {
    console.log('writeMeLater: ', data)
    setTimeout(Meteor.bindEnvironment( function() {
        Logs.insert({data: data, timestamp: new Date().getTime()})
    }), 1 * 1000)
}

Answer 1

TL;DR - 你的 writeMeLater 函数需要一个 callback 参数。

---

NodeJS 经典的异步函数通常有这样的签名:

function async(params..., callback) {
    try {
        var result = compute(params);
        callback(null,result);
    }
    catch {
        callback("something went wrong", null);
    }
}

它们接受任意数量的参数，最后一个是计算准备就绪时运行的回调，使用 2 个参数调用:error 如果一切正常则为 null，以及 结果当然。

Meteor._wrapAsync 期望获得具有此签名的函数以返回新的伪同步函数。 Meteor“同步”函数允许您以同步方式编写代码，但它们并不像 NodeJS fs.readFileSync 那样真正同步，例如，它会阻塞事件循环直到完成(通常这是不好的，除非你正在编写一个命令行应用程序，而 Meteor 则不是这种情况。

注意:在 Meteor 中使用 NodeJS fs *Sync 函数是不好的，因为你可能会误以为它们是“Meteor 同步”但它们不是，它们会阻塞你的整个 Node 进程，直到它们完成!您应该使用用 Meteor._wrapAsync 包装的 fs 异步函数。

Meteor._wrapAsync 的简化克隆看起来像这样:

var wrapAsync=function(asyncFunc) {
    // return a function who appears to run synchronously thanks to fibers/future
    return function() {
        var future = new Future();
        // take the arguments...
        var args = arguments;
        // ...and append our callback at the end
        Array.prototype.push.call(args, function(error, result) {
            if (error) {
                throw error;
            }
            // our callback calls future.return which unblocks future.wait
            future.return(result);
        });
        // call the async func with computed args
        asyncFunc.apply(null, args);
        // wait until future.return is called
        return future.wait();
    };
};

有一个 Future.wrap 正是这样做的，Meteor._wrapAsync 有点复杂，因为它使用 Meteor.bindEnvironment 处理 Meteor 环境变量。

Fibers 和 Futures 有点超出范围，所以我不会深入探讨它们，请务必查看有关该主题的 eventedmind.com 视频。

纤维介绍 - https://www.eventedmind.com/feed/BmG9WmSsdzChk8Pye

使用 future - https://www.eventedmind.com/feed/kXR6nWTKNctKariSY

meteor ._wrapAsync - https://www.eventedmind.com/feed/Ww3rQrHJo8FLgK7FF

既然您了解了在 Meteor 中封装异步函数需要做些什么，让我们来修复您的代码。

如果你的异步函数没有将回调作为最后一个参数，它不会调用它(显然)，我们在包装函数中传递给它的回调也不会触发，这意味着 future.return 赢了' 被调用，这就是您的程序首先被阻止的原因!

您只需重写 writeMeLater 以将回调作为最终参数:

var writeMeLater = function(data, callback){
    console.log('writeMeLater: ', data);
    // simulate taking 1 second to complete
    Meteor.setTimeout(function() {
        Logs.insert({
            data:data,
            timestamp:new Date().getTime()
        });
        callback(null, "done processing " + data);
    }, 1 * 1000);
};

你可以开始了!