repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Removed max tasks (#225)
[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 881813c0d9512fe9acdb7aac623e1a1f056e90c9..cc60a9b5a021253819445d46ff49fab6e91abe2f 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',
@@
-28,11
+27,18
@@
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', () => {
+ after('Destroy all pools', async () => {
+ // We need to clean up the resources after our test
+ await echoPool.destroy()
+ await asyncPool.destroy()
+ await errorPool.destroy()
+ await emptyPool.destroy()
+ })
+
it('Choose worker round robin test', async () => {
const results = new Set()
for (let i = 0; i < numberOfThreads; i++) {
it('Choose worker round robin test', async () => {
const results = new Set()
for (let i = 0; i < numberOfThreads; i++) {
@@
-88,11
+94,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()
@@
-107,5
+108,13
@@
describe('Fixed thread pool test suite', () => {
)
const res = await pool1.execute({ test: 'test' })
expect(res).toBeFalsy()
)
const res = await pool1.execute({ test: 'test' })
expect(res).toBeFalsy()
+ // 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'))
})
})
})
})