+ expect(pool.opts.tasksQueueOptions).toStrictEqual({
+ concurrency: 1,
+ size: Math.pow(numberOfWorkers, 2),
+ taskStealing: true,
+ tasksStealingOnBackPressure: true
+ })
+ for (const workerNode of pool.workerNodes) {
+ expect(workerNode.tasksQueueBackPressureSize).toBe(
+ pool.opts.tasksQueueOptions.size
+ )
+ expect(workerNode.onEmptyQueue).toBeInstanceOf(Function)
+ expect(workerNode.onBackPressure).toBeInstanceOf(Function)
+ }