this.setBackPressureFlag = true
this.info.backPressure = true
this.emit('backPressure', { workerId: this.info.id })
+ this.setBackPressureFlag = false
}
- this.setBackPressureFlag = false
return tasksQueueSize
}
) {
this.setBackPressureFlag = true
this.info.backPressure = false
+ this.setBackPressureFlag = false
}
- this.setBackPressureFlag = false
return task
}