summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
7400128)
Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>
numberOfWorkers,
'./tests/worker-files/cluster/testWorker.js'
)
numberOfWorkers,
'./tests/worker-files/cluster/testWorker.js'
)
+ 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({
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
+ 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) {
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
+ 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++) {
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
numberOfWorkers,
'./tests/worker-files/thread/testWorker.js'
)
+ 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++) {
expect(workerNode.tasksUsage.run).toBeLessThanOrEqual(maxMultiplier)
expect(workerNode.tasksQueue.size).toBe(0)
}
expect(workerNode.tasksUsage.run).toBeLessThanOrEqual(maxMultiplier)
expect(workerNode.tasksQueue.size).toBe(0)
}
})
it('Verify that is possible to have a worker that return undefined', async () => {
})
it('Verify that is possible to have a worker that return undefined', async () => {
expect(workerNode.tasksUsage.run).toBeLessThanOrEqual(maxMultiplier)
expect(workerNode.tasksQueue.size).toBe(0)
}
expect(workerNode.tasksUsage.run).toBeLessThanOrEqual(maxMultiplier)
expect(workerNode.tasksQueue.size).toBe(0)
}
})
it('Verify that is possible to have a worker that return undefined', async () => {
})
it('Verify that is possible to have a worker that return undefined', async () => {