nodejs中如何实现事件循环

nodejs中如何实现事件循环，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

process.nextTick

• process.nextTick()不在event loop的任何阶段执行，而是在各个阶段切换的中间执行；即从一个阶段切换到下个阶段前执行；

• 三种定义异步事件的方式： setTimeout,setImmediate,process.nextTick()

var fs = require('fs');fs.readFile(__dirname,() =>{    setTimeout(() =>{        console.log('setTimeout')    })        setImmediate(() =>{        console.log('setImmediate')        process.nextTick(() =>{            console.log('nextTick3')        })    })        process.nextTick(() =>{            console.log('nextTick1')    })        process.nextTick(() =>{            console.log('nextTick2')    })})// nextTick1 nextTick2 setImmediate nextTick3 setTimeout

nextTick应用场景

1. 在多个事件交叉执行cpu运算密集型的任务

var http = require('http');function compute(){    process.nextTick(compute)}http.createServer(function(req,res){// 服务请求的时候，还能抽空进行一些计算任务；    res.writeHead(200, {'Content-type': 'text/plain'})    res.end('hello world');})compute()

• 在这种模式下，我们不需要递归的调用compute(),我们只需要在事件循环中使用process.nextTict()定义;compute()在下一个事件点执行即可；在这个过程中，如果有新的http请求进来，事件循环机制会先处理新的请求，然后再调用copute().反之，如果把compute()放在一个递归里调用，那系统一直会阻塞在compute()里，无法处理新的http请求了。

2. 保持回调函数异步执行的原则

• 当给一个函数定义一个回调函数时，要确保这个回调是异步执行的(定义一个callback，但是又需要在callback里面使用这个变量)；

• 下面示例违反了这一原则：

function asyncFake(data,callback){ // 同步执行    if(data === 'foo') callback(true)    else callback(false)}asyncFake('bar',function(result){    // this callback is actually called synchronously!})

为什么这样不好呢？看下面nodejs文档里的一段代码

var client = net.connect(8124, function(){    console.log('client connect');    client.write('world'); // 会报错})

在上面的代码里，如果因为某种原因，net.connect()变成同步执行的了，回调函数就会立刻被执行，因此回调函数写到客户端的变量就用于不会被初始化了； 这种情况下我们就可以用process.nextTick()把上面的asyncFake改成异步执行的；

function asyncReal(data, callback){    process.nextTick(function(){        callback(data === 'foo')    })}

3. 用在事件触发过程中

EventEmitter 有两个比较核心的方法，on和Emit。node自带的发布/订阅模式；

var EventEmitter = require('events').EventEmmiter;function StreamLibrary(resourceName){    this.emit('start')}StreamLibrary.prototype.__proto__ = EventEmitter.prototype; // inherit from EventEmitter

var stream = new StreamLibrary('fooResouce');stream.on('start', function(){    console.log('Reading has started')})

以上代码在new StreamLibrary的时候，已经触发了emit，此时 还没有订阅，console.log不会执行 解决方案如下：用异步方法包装

function StreamLibrary(resource){    var self = this;    // 保证订阅在发布之前    process.nextTick(function(){         self.emit('start');    })// read from the file,and for every chunck read.do;this.emit('data', chunkRead)}

发布订阅模式

const EventEmitter = require('events').EventEmitter;class App extends EventEmmiter{    }let app = new App();app.on('start',() =>{ // 订阅    console.log('start');})app.emit('start') // emit 触发，emit是个同步的方法console.log(111);  // 如果需要emit是异步的，可以通过三种异步方法去包装// start 111

看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注行业资讯频道，感谢您对的支持。