const { randomInt } = require('crypto')
const { Worker } = require('worker_threads')
const cluster = require('cluster')
+const os = require('os')
const { expect } = require('expect')
const {
CircularArray,
isAsyncFunction,
isKillBehavior,
isPlainObject,
+ max,
median,
+ min,
round,
secureRandom,
sleep,
it('Verify availableParallelism() behavior', () => {
const parallelism = availableParallelism()
expect(typeof parallelism === 'number').toBe(true)
- expect(parallelism).toBeGreaterThan(0)
expect(Number.isSafeInteger(parallelism)).toBe(true)
+ let expectedParallelism = 1
+ try {
+ expectedParallelism = os.availableParallelism()
+ } catch {
+ expectedParallelism = os.cpus().length
+ }
+ expect(parallelism).toBe(expectedParallelism)
})
it('Verify getWorkerType() behavior', () => {
expect(randomNumber).toBeGreaterThanOrEqual(0)
expect(randomNumber).toBeLessThan(1)
})
+
+ it('Verify min() behavior', () => {
+ expect(min(1, 2)).toBe(1)
+ expect(min(2, 1)).toBe(1)
+ expect(min(1, 1)).toBe(1)
+ })
+
+ it('Verify max() behavior', () => {
+ expect(max(1, 2)).toBe(2)
+ expect(max(2, 1)).toBe(2)
+ expect(max(1, 1)).toBe(1)
+ })
})