repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
test: fix flakiness
[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 a5976d99d88d16d381d2e82cd56889ec91539d91..933e1f944f863bdbcdb4110c1d75359e8f571b4c 100644
(file)
--- a/
tests/pools/abstract/abstract-pool.test.js
+++ b/
tests/pools/abstract/abstract-pool.test.js
@@
-618,6
+618,7
@@
describe('Abstract pool test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ stolen: 0,
failed: 0
},
runTime: {
failed: 0
},
runTime: {
@@
-710,6
+711,7
@@
describe('Abstract pool test suite', () => {
executing: maxMultiplier,
queued: 0,
maxQueued: 0,
executing: maxMultiplier,
queued: 0,
maxQueued: 0,
+ stolen: 0,
failed: 0
},
runTime: {
failed: 0
},
runTime: {
@@
-736,6
+738,7
@@
describe('Abstract pool test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ stolen: 0,
failed: 0
},
runTime: {
failed: 0
},
runTime: {
@@
-776,6
+779,7
@@
describe('Abstract pool test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ stolen: 0,
failed: 0
},
runTime: {
failed: 0
},
runTime: {
@@
-810,6
+814,7
@@
describe('Abstract pool test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ stolen: 0,
failed: 0
},
runTime: {
failed: 0
},
runTime: {
@@
-956,11
+961,11
@@
describe('Abstract pool test suite', () => {
++poolBackPressure
poolInfo = info
})
++poolBackPressure
poolInfo = info
})
- for (let i = 0; i < numberOfWorkers
* 2
; i++) {
+ for (let i = 0; i < numberOfWorkers
+ 1
; i++) {
promises.add(pool.execute())
}
await Promise.all(promises)
promises.add(pool.execute())
}
await Promise.all(promises)
- expect(poolBackPressure).toBe(
2
)
+ expect(poolBackPressure).toBe(
1
)
expect(poolInfo).toStrictEqual({
version,
type: PoolTypes.fixed,
expect(poolInfo).toStrictEqual({
version,
type: PoolTypes.fixed,
@@
-977,6
+982,7
@@
describe('Abstract pool test suite', () => {
maxQueuedTasks: expect.any(Number),
queuedTasks: expect.any(Number),
backPressure: true,
maxQueuedTasks: expect.any(Number),
queuedTasks: expect.any(Number),
backPressure: true,
+ stolenTasks: expect.any(Number),
failedTasks: expect.any(Number)
})
expect(pool.hasBackPressure.called).toBe(true)
failedTasks: expect.any(Number)
})
expect(pool.hasBackPressure.called).toBe(true)
@@
-1040,7
+1046,8
@@
describe('Abstract pool test suite', () => {
executed: expect.any(Number),
executing: expect.any(Number),
failed: 0,
executed: expect.any(Number),
executing: expect.any(Number),
failed: 0,
- queued: 0
+ queued: 0,
+ stolen: 0
},
runTime: {
history: expect.any(CircularArray)
},
runTime: {
history: expect.any(CircularArray)