- this.tasksUsage = new Map<string, WorkerUsage>()
- this.tasksQueue = new Queue<Task<Data>>()
+ if (this.info.type === WorkerTypes.thread) {
+ this.messageChannel = new MessageChannel()
+ }
+ // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
+ this.tasksQueueBackPressureSize = opts.tasksQueueBackPressureSize!
+ this.tasksQueue = new PriorityQueue<Task<Data>>(
+ opts.tasksQueueBucketSize,
+ opts.tasksQueuePriority
+ )
+ this.setBackPressureFlag = false
+ this.taskFunctionsUsage = new Map<string, WorkerUsage>()
+ }
+
+ /** @inheritdoc */
+ public setTasksQueuePriority (enablePriority: boolean): void {
+ this.tasksQueue.enablePriority = enablePriority