import {
CircularArray,
DEFAULT_CIRCULAR_ARRAY_SIZE
-} from '../../lib/circular-array.js'
+} from '../../lib/circular-array.cjs'
import {
createWorker,
getDefaultTasksQueueOptions,
updateMeasurementStatistics
-} from '../../lib/pools/utils.js'
-import { WorkerTypes } from '../../lib/index.js'
+} from '../../lib/pools/utils.cjs'
+import { WorkerTypes } from '../../lib/index.cjs'
describe('Pool utils test suite', () => {
it('Verify getDefaultTasksQueueOptions() behavior', () => {
size: Math.pow(poolMaxSize, 2),
taskStealing: true,
tasksStealingOnBackPressure: true,
- tasksFinishedTimeout: 1000
+ tasksFinishedTimeout: 2000
})
})
expect(
createWorker(
WorkerTypes.thread,
- './tests/worker-files/thread/testWorker.mjs'
+ './tests/worker-files/thread/testWorker.mjs',
+ {}
)
).toBeInstanceOf(ThreadWorker)
expect(
createWorker(
WorkerTypes.cluster,
- './tests/worker-files/cluster/testWorker.mjs'
+ './tests/worker-files/cluster/testWorker.mjs',
+ {}
)
).toBeInstanceOf(ClusterWorker)
})