Package lock to 2.0.0 and removing other full keywords
[poolifier.git] / tests / pools / thread / fixed.test.js
index 9a2d74d30bc2f2bb194effd9494b90bf7252b6ed..b70d4c624c5d9744494c6ac87ed9f290e1633221 100644 (file)
@@ -2,7 +2,6 @@ const expect = require('expect')
 const { FixedThreadPool } = require('../../../lib/index')
 const TestUtils = require('../../test-utils')
 const numberOfThreads = 10
-const maxTasks = 400
 const pool = new FixedThreadPool(
   numberOfThreads,
   './tests/worker-files/thread/testWorker.js',
@@ -12,7 +11,8 @@ const pool = new FixedThreadPool(
 )
 const emptyPool = new FixedThreadPool(
   1,
-  './tests/worker-files/thread/emptyWorker.js'
+  './tests/worker-files/thread/emptyWorker.js',
+  { exitHandler: () => console.log('WORKER EXITED') }
 )
 const echoPool = new FixedThreadPool(
   1,
@@ -28,8 +28,7 @@ const errorPool = new FixedThreadPool(
 )
 const asyncPool = new FixedThreadPool(
   1,
-  './tests/worker-files/thread/asyncWorker.js',
-  { maxTasks: maxTasks }
+  './tests/worker-files/thread/asyncWorker.js'
 )
 
 describe('Fixed thread pool test suite', () => {
@@ -96,11 +95,6 @@ describe('Fixed thread pool test suite', () => {
     expect(usedTime).toBeGreaterThanOrEqual(2000)
   })
 
-  it('Verify that maxTasks is set properly', async () => {
-    const worker = asyncPool.chooseWorker()
-    expect(worker.port2.getMaxListeners()).toBe(maxTasks)
-  })
-
   it('Shutdown test', async () => {
     const exitPromise = TestUtils.waitExits(pool, numberOfThreads)
     await pool.destroy()