const { WorkerFunctions } = require('../../test-types')
const TestUtils = require('../../test-utils')
const { WorkerFunctions } = require('../../test-types')
const TestUtils = require('../../test-utils')
}
expect(queuePool.numberOfRunningTasks).toBe(numberOfThreads)
expect(queuePool.numberOfQueuedTasks).toBe(
}
expect(queuePool.numberOfRunningTasks).toBe(numberOfThreads)
expect(queuePool.numberOfQueuedTasks).toBe(
for (const workerNode of queuePool.workerNodes) {
expect(workerNode.tasksUsage.running).toBe(0)
expect(workerNode.tasksUsage.run).toBeGreaterThan(0)
for (const workerNode of queuePool.workerNodes) {
expect(workerNode.tasksUsage.running).toBe(0)
expect(workerNode.tasksUsage.run).toBeGreaterThan(0)
expect(inError.message).toBeDefined()
expect(typeof inError.message === 'string').toBe(true)
expect(inError.message).toBe('Error Message from ThreadWorker')
expect(inError.message).toBeDefined()
expect(typeof inError.message === 'string').toBe(true)
expect(inError.message).toBe('Error Message from ThreadWorker')
expect(inError.message).toBeDefined()
expect(typeof inError.message === 'string').toBe(true)
expect(inError.message).toBe('Error Message from ThreadWorker:async')
expect(inError.message).toBeDefined()
expect(typeof inError.message === 'string').toBe(true)
expect(inError.message).toBe('Error Message from ThreadWorker:async')