repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Rename FullPool event to busy, update benchmarks
[poolifier.git]
/
tests
/
pools
/
thread
/
fixed.test.js
diff --git
a/tests/pools/thread/fixed.test.js
b/tests/pools/thread/fixed.test.js
index cea5502508261b85bf96cc680ab4021e81498ad7..b70d4c624c5d9744494c6ac87ed9f290e1633221 100644
(file)
--- a/
tests/pools/thread/fixed.test.js
+++ b/
tests/pools/thread/fixed.test.js
@@
-2,7
+2,6
@@
const expect = require('expect')
const { FixedThreadPool } = require('../../../lib/index')
const TestUtils = require('../../test-utils')
const numberOfThreads = 10
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',
const pool = new FixedThreadPool(
numberOfThreads,
'./tests/worker-files/thread/testWorker.js',
@@
-12,7
+11,8
@@
const pool = new FixedThreadPool(
)
const emptyPool = new FixedThreadPool(
1,
)
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,
)
const echoPool = new FixedThreadPool(
1,
@@
-28,8
+28,7
@@
const errorPool = new FixedThreadPool(
)
const asyncPool = new FixedThreadPool(
1,
)
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', () => {
)
describe('Fixed thread pool test suite', () => {
@@
-96,11
+95,6
@@
describe('Fixed thread pool test suite', () => {
expect(usedTime).toBeGreaterThanOrEqual(2000)
})
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()
it('Shutdown test', async () => {
const exitPromise = TestUtils.waitExits(pool, numberOfThreads)
await pool.destroy()
@@
-118,4
+112,10
@@
describe('Fixed thread pool test suite', () => {
// We need to clean up the resources after our test
await pool1.destroy()
})
// We need to clean up the resources after our test
await pool1.destroy()
})
+
+ it('Verify that a pool with zero worker fails', async () => {
+ expect(
+ () => new FixedThreadPool(0, './tests/worker-files/thread/testWorker.js')
+ ).toThrowError(new Error('Cannot instantiate a fixed pool with no worker'))
+ })
})
})