type: WorkerTypes.thread,
dynamic: false,
ready: false,
- backPressure: false,
- stealing: false
+ stealing: false,
+ backPressure: false
})
expect(threadWorkerNode.usage).toStrictEqual({
tasks: {
expect(threadWorkerNode.tasksQueueBackPressureSize).toBe(12)
expect(threadWorkerNode.tasksQueue).toBeInstanceOf(PriorityQueue)
expect(threadWorkerNode.tasksQueue.size).toBe(0)
- expect(threadWorkerNode.tasksQueue.k).toBe(6)
+ expect(threadWorkerNode.tasksQueue.bucketSize).toBe(6)
expect(threadWorkerNode.tasksQueueSize()).toBe(
threadWorkerNode.tasksQueue.size
)
type: WorkerTypes.cluster,
dynamic: false,
ready: false,
- backPressure: false,
- stealing: false
+ stealing: false,
+ backPressure: false
})
expect(clusterWorkerNode.usage).toStrictEqual({
tasks: {
expect(clusterWorkerNode.tasksQueueBackPressureSize).toBe(12)
expect(clusterWorkerNode.tasksQueue).toBeInstanceOf(PriorityQueue)
expect(clusterWorkerNode.tasksQueue.size).toBe(0)
- expect(clusterWorkerNode.tasksQueue.k).toBe(6)
+ expect(clusterWorkerNode.tasksQueue.bucketSize).toBe(6)
expect(clusterWorkerNode.tasksQueueSize()).toBe(
clusterWorkerNode.tasksQueue.size
)