nodejs中如何实现事件循环

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

成都创新互联公司坚信:善待客户,将会成为终身客户。我们能坚持多年,是因为我们一直可值得信赖。我们从不忽悠初访客户,我们用心做好本职工作,不忘初心,方得始终。10余年网站建设经验成都创新互联公司是成都老牌网站营销服务商,为您提供网站建设、网站制作、网站设计、H5网站设计、网站制作、高端网站设计、成都微信小程序服务,给众多知名企业提供过好品质的建站服务。

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请求了。

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

  • 当给一个函数定义一个回调函数时,要确保这个回调是异步执行的(定义一个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')
    })
}
  1. 用在事件触发过程中

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

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


当前名称:nodejs中如何实现事件循环
网站网址:http://scyanting.com/article/gggeph.html