- // TODO: Create a better test to cover `LessBusyWorkerChoiceStrategy#choose`
- const promises = []
- for (let i = 0; i < max * 2; i++) {
- promises.push(pool.execute())
- }
- await Promise.all(promises)
- // We need to clean up the resources after our test
- await pool.destroy()
- })
-
- it('Verify FAIR_SHARE strategy is taken at pool creation', async () => {
- const pool = new FixedThreadPool(
- max,
- './tests/worker-files/thread/testWorker.js',
- { workerChoiceStrategy: WorkerChoiceStrategies.FAIR_SHARE }
- )
- expect(pool.opts.workerChoiceStrategy).toBe(
- WorkerChoiceStrategies.FAIR_SHARE
- )
- for (const workerNodeKey of pool.workerChoiceStrategyContext.workerChoiceStrategies
- .get(WorkerChoiceStrategies.FAIR_SHARE)
- .workerLastVirtualTaskTimestamp.keys()) {
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies
- .get(WorkerChoiceStrategies.FAIR_SHARE)
- .workerLastVirtualTaskTimestamp.get(workerNodeKey).start
- ).toBe(0)
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies
- .get(WorkerChoiceStrategies.FAIR_SHARE)
- .workerLastVirtualTaskTimestamp.get(workerNodeKey).end
- ).toBe(0)
+ // TODO: Create a better test to cover `LeastBusyWorkerChoiceStrategy#choose`
+ const maxMultiplier = 2
+ for (let i = 0; i < max * maxMultiplier; i++) {
+ await pool.execute()