理解Nodejs的Event Loop

简介:

Node的“event loop”主要是用来处理高输出量的。这很神奇,这也是为什么node可以在单线程的情况下同时处理很多的后台操作。本文就会集中讲述event loop是怎么运行的,这样你可以可以使用这个神奇的东西完成你自己的工作。

 

事件驱动的编程(event-driven programming)

要理解event loop首先需要了解的就是event driven programming(事件驱动的编程)。这个在1960年代就已经被人们所熟知。如今,event-driven proggramming被广泛的应用在UI处理中。javascript主要用在处理DOM中。

定义非常简单:event-driven programming就是程序的控制流程是由事件或者状态的改变决定的。主要的实现机制就是用一个中心控制台监听事件,并在事件发生的时候调用这个事件对应的回调函数(状态的改变也是一样)。很熟悉吧?这就是node的event loop的处理机制。

浏览器中的javascript开发中常常会遇到.on*()的方法,比如element.onclick(),用于连接用户操作和DOM。这个模式在一个单一元素可以发出多种可能的事件的时候工作的非常好。Node在EventEmitter中使用了这个模式,这个模式主要用在了server,socket和‘http’等模块中。这在一个实例需要发出多种类型的事件和状态的时候非常有用。

另一个普遍使用的模式是成功和失败。主流的实现方法有两种。第一个是发生错误的回调(原文:“error back”),就是在发生错误的时候把error作为第一个参数调用回调函数。另一种方法是在ES6中定义的,使用Promises。

‘fs’模块中大量使用了‘error back’。技术上来说,某些调用会发出其他的事件。比如,fs.readFile()。但是只在成功或者失败的时候才提醒用户。API这么设计主要是出于系统策略,不是技术的限制。

两一个很大的误解是事件发生机制本身是异步的。但是,这是不对的。下面的代码会表明这一点:

复制代码
var EventEmitter = require('events').EventEmitter;
var util = require('util');

function MyEmitter() {
    EventEmitter.call(this);
}
util.inherits(MyEmitter, EventEmitter);

MyEmitter.prototype.doStuff = function() {
    console.log('before');
    this.emit('fire');
    console.log('after');
}

var me = new MyEmitter();
me.on('fire', function(){
    console.log('emit fired');
});

me.doStuff();

// Output:
// before
// emit fired
// after
复制代码

EventEmitter看起来是异步的,因为他总是被用来发出异步操作完成的信号。但是,EventEmitter API是完全同步的。emit方法可能被异步调用,但是需要主要到全部的监听方法都是按照添加的顺序同步执行的。

 

总览

Node本身依赖于很多的库。其中之一就是libuv。这个库就是用来处理队列和异步的事件的。Node极大限度的使用了操作系统核心已经有的功能。申请写操作,保持连接以及更多地由系统处理的功能。比如,连接申请被系统排队,直到被Node处理。

你也许了解过Node有一个线程池,也会想知道“如果node把这些职责都推掉了,那还需要什么线程池?” 这是因为系统核心并不支持什么事都异步执行。比如,有时node需要锁定某个线程,这样event loop可以一直执行而不至于死锁。

这里有一个简化的图来解释event loop是怎么运行的。

diagram

有一些event loop的内部执行机制很难在图中给出:

  • 所有使用process.nexTick()指定的回调都会在event loop的某阶段的最后时刻,在进入下一个阶段前被执行(比如,timer)。这样有一个潜在的风险,如果process.nextTrick()方法有递归调用的话,整个event loop就被拖死了。
  • “待处理队列(pending callbacks)”就是未被其他阶段(phase)处理的回调队列(比如:给fs.write()传进去的回调)。

 

Event Emitter和Event Loop

为了简化和Event loop的互操作,所以有了EventEmitter。用EventEmitter可以很容易创建一个基于事件的API。下面我们就一些主要内容做讲解。

下面的代码展示了没有同步发出事件会造成用户错过事件的情况:

复制代码
var EventEmitter = require('events').EventEmitter;
var util = require('util');

function MyThing() {
    EventEmitter.call(this);
    
    doFirstThing();
    this.emit('thing1');
}
util.inherites(MyThing, EventEmitter);

var mt = new MyThing();

mt.on('thing1', function(){
    // never going to happen.
});
复制代码

以上代码的问题就在于‘thing1’永远不会被用户捕捉到,因为MyThing()必须在初始化完成之后才能监听事件。下面是一个简单地解决方案,不需要任何另外的闭包:

复制代码
var EventEmitter = require('events').EventEmitter;
var util = require('util');

function MyThing() {
    EventEmitter.call(this);
    
    // doFirstThing();
    // this.emit('thing1');
    setImmediate(emitThing1, this);
}
util.inherits(MyThing, EventEmitter);

function emitThing1(self) {
    self.emit('thing1');
}

var mt = new MyThing();

mt.on('thing1', function(){
    // bravo
    console.log('bravo, thing1 captured.');
});

// bravo, thing1 captured.
复制代码

下面的代码页可以运行,只不过消耗较多。

复制代码
function MyThing() {
    EventEmitter.call(this);
    
    // doFirstThing();
    // this.emit('thing1');
    // setImmediate(emitThing1, this);
    setImmediate(this.emit.bind(this, 'thing1'));
}
复制代码

另一种情况是触发错误。查出你的应用的问题非常麻烦,而且如果没有调用栈的话,简直无法排查。一个Error在异步执行的深处初始化的时候可能会导致调用栈丢失。解决这个问题最靠谱的两个办法就是同步emit事件,或者确保Error带了足够的相关信息。请看以下代码的演示:

复制代码
MyThing.prototype.foo = function () {
    var er = doFirstThing();
    if (er) {
        // emit error asynchronously
        setImmediate(emitError, this, new Error('Bad stuff'));
        return;
    }
    
    // emit error synchronously
    var er = doSecondThing();
    if (er) {
        this.emit('error', 'More bad stuff');
        return;
    }
};
复制代码

emit的错误应该立即被处理,以防程序继续执行。而且在构造函数中emit错误也不是个好主意。

 

最后

本文只介绍了event loop知识的一小部分。这些会在之后的文章中补足。但是,这是继续下去之前必备的基础。之后的文章会讲述event loop是怎么和系统的核心互相交互的。

 

欢迎加群互相学习,共同进步。QQ群:iOS: 58099570 | Android: 330987132 | Go:217696290 | Python:336880185 | 做人要厚道,转载请注明出处!
相关文章
|
3月前
|
存储 JavaScript 前端开发
说说你对Event Loop的理解是什么
Event Loop(事件循环)是JavaScript中处理异步操作的一种机制,它帮助我们协调和处理各种任务的执行顺序。
29 0
|
8月前
|
移动开发 JavaScript 前端开发
说说你对事件循环event loop的理解?
说说你对事件循环event loop的理解?
70 0
|
8月前
|
JavaScript
【说说你对事件循环event loop的理解】
【说说你对事件循环event loop的理解】
|
8月前
|
JavaScript
event loop的理解
event loop的理解
|
8月前
|
JavaScript 前端开发
说说你对事件循环的理解(event loop)
说说你对事件循环的理解(event loop)
|
9月前
|
移动开发 JavaScript 前端开发
Event Loop 事件循环简介
Event Loop 事件循环简介
97 0
|
9月前
浅析Event Loop(事件循环)
浅析Event Loop(事件循环)
64 0
|
9月前
|
移动开发 前端开发 JavaScript
事件循环(Event Loop)
JavaScript 是一门单线程语言,这意味着它只有一个主线程来执行代码。这个主线程会按照代码的顺序执行任务,而且同一时间只能执行一个任务。
|
JavaScript 前端开发
我不知道的Event Loop(事件循环)
我不知道的Event Loop(事件循环)
我不知道的Event Loop(事件循环)
|
JavaScript 前端开发 API
Js 的事件循环(Event Loop)机制以及实例讲解
前言 大家都知道js是单线程的脚本语言,在同一时间,只能做同一件事,为了协调事件、用户交互、脚本、UI渲染和网络处理等行为,防止主线程阻塞,Event Loop方案应运而生... 个人博客了解一下:obkoro1.com 为什么js是单线程? js作为主要运行在浏览器的脚本语言,js主要用途之一是操作DOM。 在js高程中举过一个栗子,如果js同时有两个线程,同时对同一个dom进行操作,这时浏览器应该听哪个线程的,如何判断优先级? 为了避免这种问题,js必须是一门单线程语言,并且在未来这个特点也不会改变。
158 0
Js 的事件循环(Event Loop)机制以及实例讲解