repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
test: import RR worker choice strategy expectation
[poolifier.git]
/
tests
/
pools
/
abstract
/
abstract-pool.test.js
diff --git
a/tests/pools/abstract/abstract-pool.test.js
b/tests/pools/abstract/abstract-pool.test.js
index 108fb32a03f1c10d629a9a4bf33da46e4169987d..05abdc69d7c31369f42db85505531aa77022f9d3 100644
(file)
--- a/
tests/pools/abstract/abstract-pool.test.js
+++ b/
tests/pools/abstract/abstract-pool.test.js
@@
-327,10
+327,10
@@
describe('Abstract pool test suite', () => {
numberOfWorkers,
'./tests/worker-files/cluster/testWorker.js'
)
numberOfWorkers,
'./tests/worker-files/cluster/testWorker.js'
)
- const promises =
[]
+ const promises =
new Set()
const maxMultiplier = 2
for (let i = 0; i < numberOfWorkers * maxMultiplier; i++) {
const maxMultiplier = 2
for (let i = 0; i < numberOfWorkers * maxMultiplier; i++) {
- promises.
push
(pool.execute())
+ promises.
add
(pool.execute())
}
for (const workerNode of pool.workerNodes) {
expect(workerNode.tasksUsage).toStrictEqual({
}
for (const workerNode of pool.workerNodes) {
expect(workerNode.tasksUsage).toStrictEqual({
@@
-372,10
+372,10
@@
describe('Abstract pool test suite', () => {
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
- const promises =
[]
+ const promises =
new Set()
const maxMultiplier = 2
for (let i = 0; i < numberOfWorkers * maxMultiplier; i++) {
const maxMultiplier = 2
for (let i = 0; i < numberOfWorkers * maxMultiplier; i++) {
- promises.
push
(pool.execute())
+ promises.
add
(pool.execute())
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
@@
-422,11
+422,11
@@
describe('Abstract pool test suite', () => {
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
- const promises =
[]
+ const promises =
new Set()
let poolFull = 0
pool.emitter.on(PoolEvents.full, () => ++poolFull)
for (let i = 0; i < numberOfWorkers * 2; i++) {
let poolFull = 0
pool.emitter.on(PoolEvents.full, () => ++poolFull)
for (let i = 0; i < numberOfWorkers * 2; i++) {
- promises.
push
(pool.execute())
+ promises.
add
(pool.execute())
}
await Promise.all(promises)
// The `full` event is triggered when the number of submitted tasks at once reach the max number of workers in the dynamic pool.
}
await Promise.all(promises)
// The `full` event is triggered when the number of submitted tasks at once reach the max number of workers in the dynamic pool.
@@
-440,11
+440,11
@@
describe('Abstract pool test suite', () => {
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
- const promises =
[]
+ const promises =
new Set()
let poolBusy = 0
pool.emitter.on(PoolEvents.busy, () => ++poolBusy)
for (let i = 0; i < numberOfWorkers * 2; i++) {
let poolBusy = 0
pool.emitter.on(PoolEvents.busy, () => ++poolBusy)
for (let i = 0; i < numberOfWorkers * 2; i++) {
- promises.
push
(pool.execute())
+ promises.
add
(pool.execute())
}
await Promise.all(promises)
// The `busy` event is triggered when the number of submitted tasks at once reach the number of fixed pool workers.
}
await Promise.all(promises)
// The `busy` event is triggered when the number of submitted tasks at once reach the number of fixed pool workers.