javascript - 使用 EventEmitter 编写异步函数

Question

我是节点新手，尝试在节点中使用异步和事件行为优势。我曾经从节点理解，所有处理事件对象的东西，都将是异步执行。
然后我尝试了这个，考虑以下代码：

var events = require("events");

var event = new events.EventEmitter();


event.on("work", function () {

    for (var i = 0; i <= 10; i++) {
        console.log("I do my work " + i);
    }

    event.emit("done");
});

var async = function (cb) {

    event.on("done", cb);
    event.emit("work");
    for (var i = 0; i <= 10; i++) {
        console.log("Async " + i);
    }
}


async(function () {
    console.log("I am done callback!");
});  

这是异步执行？在我看来没有！为什么，因为我读过很多次这句话：

一个事件被触发了，所以去做一些事情，然后当你完成它时，回来告诉我，但与此同时我会做其他事情。

就像快餐店的场景。但是上面的代码，当事件工作将被触发时，将发生以下序列：

1. 进入回调
2. 让循环
3. 输出我做我的工作 n
4. 触发了 done 事件
5. 输出我完成回调！
6. 输出异步 n

为什么我完成回调！会在 Async n 之前输出吗？为什么这里不像快餐店的场景，像

工作事件被触发，去做你的事情，完成后回来，同时我将输出 Async n

这是我用来了解事件驱动行为和节点中的异步的。但现在我很困惑。我知道，javascript 适用于单线程。如何使用事件发射器编写异步函数？但我认为这是不可能的，因为当我发出一个事件时，它会立即执行处理程序。

Answer 1

我曾经从节点理解，所有处理事件对象的东西，都将是异步执行。

这是不正确的。事件是同步的。添加侦听器时，您只是将回调保存在对象中：

this._events[type].push(listener);

当您发出一个事件时，您只是在迭代一个数组并调用每个侦听器：

for (i = 0; i < len; i++)
      listeners[i].apply(this, args);

源代码：https ://github.com/joyent/node/blob/master/lib/events.js

这是异步执行？在我看来没有！

你是对的。如果您调用任何 I/O 函数或 use或计时器setImmediate，nextTick则它是异步的——否则，它是同步的。异步编写的同步代码不会将其转换为异步代码。

为什么我完成回调！会在 Async n 之前输出吗？

因为当您收到“完成”回调时，您会调用“cb”：

event.on("done", cb);

返回时cb，执行“Async n”循环。

如何使用事件发射器编写异步函数？

使用setImmediate或process.nextTick。

如果你想推迟“我做我的工作”循环的执行，你可以events.emit ("work")用nextTick.

var events = require("events");

var event = new events.EventEmitter();


event.on("work", function () {

    for (var i = 0; i <= 10; i++) {
        console.log("I do my work " + i);
    }

    event.emit("done");
});

var async = function (cb) {

    event.on("done", cb);
    process.nextTick (function () {         //<-----
        event.emit("work");
    });                                     //<-----
    for (var i = 0; i <= 10; i++) {
        console.log("Async " + i);
    }
}


async(function () {
    console.log("I am done callback!");
});  

这将打印：

Async 0
Async 1
Async 2
Async 3
Async 4
Async 5
Async 6
Async 7
Async 8
Async 9
Async 10
I do my work 0
I do my work 1
I do my work 2
I do my work 3
I do my work 4
I do my work 5
I do my work 6
I do my work 7
I do my work 8
I do my work 9
I do my work 10
I am done callback!