当前位置: 首页 > 工具软件 > EventProxy > 使用案例 >

Nodejs 使用eventproxy来控制并发

史钊
2023-12-01

本质上来讲 eventproxy 是一个高级的计数器

这一句,监听了多个自定义事件,每次当一个异步操作完成时,就通过 ep.emit() 来告诉 ep 自己,某某事件已经完成了,并传递参数。
当事件未同时完成时,ep.emit() 调用之后不会做任何事;个事件都完成的时候,就会调用末尾的那个回调函数,来对它们进行统一处理。且自定义事件需要控制在五个以内

npm i eventproxy --save

const Eventproxy = require('eventproxy')

let ep = new Eventproxy()

ep.all('action1','action2','action3', (data1,data2,data3) => {
    console.log(data1,data2,data3)
})

let action1 = new Promise((resolve,reject) => {
    if(Code()){
        resolve('data1')
    }

})

let action2 = new Promise((resolve,reject) => {
    if(Code()){
        resolve('data2')
    }

})

let action3 = new Promise((resolve,reject) => {
    if(Code()){
        resolve('data3')
    }

})

action1.then( (data) => {
    ep.emit('action1',data)
})

action2.then( (data) => {
    ep.emit('action2',data)
})

action3.then( (data) => {
    ep.emit('action3',data)
})


 类似资料: