tests/dynamic.test.js

   1 const expect = require('expect')
   2 const DynamicThreadPool = require('../lib/dynamic')
   3 const min = 1
   4 const max = 3
   5 const pool = new DynamicThreadPool(min, max,
   6   './tests/testWorker.js',
   7   { errorHandler: (e) => console.error(e), onlineHandler: () => console.log('worker is online') })
   8
   9 describe('Dynamic thread pool test suite ', () => {
  10   it('Verify that the function is executed in a worker thread', async () => {
  11     const result = await pool.execute({ test: 'test' })
  12     expect(result).toBeDefined()
  13     expect(result).toBeFalsy()
  14   })
  15
  16   it('Verify that new workers are created when required, max size is not exceeded and that after a while new workers will die', async () => {
  17     const promises = []
  18     let closedThreads = 0
  19     let fullPool = 0
  20     pool.emitter.on('FullPool', () => fullPool++)
  21     for (let i = 0; i < (max * 2); i++) {
  22       promises.push(pool.execute({ test: 'test' }))
  23     }
  24     expect(pool.workers.length).toBe(max)
  25     pool.workers.forEach(w => {
  26       w.on('exit', () => {
  27         closedThreads++
  28       })
  29     })
  30     expect(fullPool > 1).toBeTruthy()
  31     await new Promise(resolve => setTimeout(resolve, 2000))
  32     expect(closedThreads).toBe(max - min)
  33   })
  34
  35   it('Shutdown test', async () => {
  36     let closedThreads = 0
  37     pool.workers.forEach(w => {
  38       w.on('exit', () => {
  39         closedThreads++
  40       })
  41     })
  42     pool.destroy()
  43     await new Promise(resolve => setTimeout(resolve, 2000))
  44     expect(closedThreads).toBe(min)
  45   })
  46
  47   it('Validations test', () => {
  48     let error
  49     try {
  50       const pool1 = new DynamicThreadPool()
  51       console.log(pool1)
  52     } catch (e) {
  53       error = e
  54     }
  55     expect(error).toBeTruthy()
  56     expect(error.message).toBeTruthy()
  57   })
  58
  59   it('Should work even without opts in input', async () => {
  60     const pool1 = new DynamicThreadPool(1, 1, './tests/testWorker.js')
  61     const res = await pool1.execute({ test: 'test' })
  62     expect(res).toBeFalsy()
  63   })
  64 })