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
}
type: getWorkerType(worker)!,
dynamic: false,
ready: false,
- backPressure: false,
- stealing: false
+ stealing: false,
+ backPressure: false
}
}