const { expect } = require('expect')
-const { DynamicThreadPool, PoolEvents } = require('../../../lib/index')
+const { DynamicThreadPool, PoolEvents } = require('../../../lib')
const { WorkerFunctions } = require('../../test-types')
const TestUtils = require('../../test-utils')
let result = await pool.execute({
function: WorkerFunctions.fibonacci
})
- expect(result).toBe(false)
+ expect(result).toBe(121393)
result = await pool.execute({
function: WorkerFunctions.factorial
})
- expect(result).toBe(false)
+ expect(result).toBe(9.33262154439441e157)
})
it('Verify that new workers are created when required, max size is not exceeded and that after a while new workers will die', async () => {
it('Verify scale thread up and down is working', async () => {
expect(pool.workerNodes.length).toBe(min)
- for (let i = 0; i < max * 10; i++) {
+ for (let i = 0; i < max * 2; i++) {
pool.execute()
}
expect(pool.workerNodes.length).toBe(max)
await TestUtils.waitExits(pool, max - min)
expect(pool.workerNodes.length).toBe(min)
- for (let i = 0; i < max * 10; i++) {
+ for (let i = 0; i < max * 2; i++) {
pool.execute()
}
expect(pool.workerNodes.length).toBe(max)
}
)
expect(longRunningPool.workerNodes.length).toBe(min)
- for (let i = 0; i < max * 10; i++) {
+ for (let i = 0; i < max * 2; i++) {
longRunningPool.execute()
}
expect(longRunningPool.workerNodes.length).toBe(max)
}
)
expect(longRunningPool.workerNodes.length).toBe(min)
- for (let i = 0; i < max * 10; i++) {
+ for (let i = 0; i < max * 2; i++) {
longRunningPool.execute()
}
expect(longRunningPool.workerNodes.length).toBe(max)