- const tasksQueueSize = this.tasksQueue.push(task)
- if (
- this.onBackPressure != null &&
- this.hasBackPressure() &&
- !this.onBackPressureStarted
- ) {
- this.onBackPressureStarted = true
- this.onBackPressure(this.info.id as number)
- this.onBackPressureStarted = false
- }
- return tasksQueueSize
- }
-
- /** @inheritdoc */
- public unshiftTask (task: Task<Data>): number {
- const tasksQueueSize = this.tasksQueue.unshift(task)
- if (
- this.onBackPressure != null &&
- this.hasBackPressure() &&
- !this.onBackPressureStarted
- ) {
+ const tasksQueueSize = this.tasksQueue.enqueue(task, task.priority)
+ if (this.hasBackPressure() && !this.onBackPressureStarted) {