+
+ it('Verify getWorkerChoiceStrategyRetries() behavior', async () => {
+ const numberOfThreads = 4
+ const pool = new FixedThreadPool(
+ numberOfThreads,
+ './tests/worker-files/thread/testWorker.mjs'
+ )
+ expect(getWorkerChoiceStrategyRetries(pool)).toBe(pool.info.maxSize * 2)
+ await pool.destroy()
+ })
+
+ it('Verify buildWorkerChoiceStrategyOptions() behavior', async () => {
+ const numberOfWorkers = 4
+ const pool = new FixedClusterPool(
+ numberOfWorkers,
+ './tests/worker-files/cluster/testWorker.cjs'
+ )
+ expect(buildWorkerChoiceStrategyOptions(pool)).toStrictEqual({
+ runTime: { median: false },
+ waitTime: { median: false },
+ elu: { median: false },
+ weights: expect.objectContaining({
+ 0: expect.any(Number),
+ [pool.info.maxSize - 1]: expect.any(Number)
+ })
+ })
+ await pool.destroy()
+ })
+
+ // it('Verify once()', () => {
+ // let called = 0
+ // const fn = () => ++called
+ // const onceFn = once(fn, this)
+ // const result1 = onceFn()
+ // expect(called).toBe(1)
+ // expect(result1).toBe(1)
+ // const result2 = onceFn()
+ // expect(called).toBe(1)
+ // expect(result2).toBe(1)
+ // const result3 = onceFn()
+ // expect(called).toBe(1)
+ // expect(result3).toBe(1)
+ // })