benchmarks/internal/cluster/fixed.js

   1 const {
   2   FixedClusterPool,
   3   WorkerChoiceStrategies
   4 } = require('../../../lib/index')
   5 const { runPoolifierTest } = require('../../benchmarks-utils')
   6
   7 const size = 30
   8 const numberOfTasks = 1
   9
  10 const fixedPool = new FixedClusterPool(
  11   size,
  12   './benchmarks/internal/cluster/worker.js'
  13 )
  14
  15 const fixedPoolLessRecentlyUsed = new FixedClusterPool(
  16   size,
  17   './benchmarks/internal/cluster/worker.js',
  18   { workerChoiceStrategy: WorkerChoiceStrategies.LESS_USED }
  19 )
  20
  21 const fixedPoolWeightedRoundRobin = new FixedClusterPool(
  22   size,
  23   './benchmarks/internal/cluster/worker.js',
  24   { workerChoiceStrategy: WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN }
  25 )
  26
  27 const fixedPoolFairShare = new FixedClusterPool(
  28   size,
  29   './benchmarks/internal/cluster/worker.js',
  30   { workerChoiceStrategy: WorkerChoiceStrategies.FAIR_SHARE }
  31 )
  32
  33 async function fixedClusterTest (
  34   { tasks, workerData } = { tasks: numberOfTasks, workerData: { proof: 'ok' } }
  35 ) {
  36   return runPoolifierTest(fixedPool, { tasks, workerData })
  37 }
  38
  39 async function fixedClusterTestLessRecentlyUsed (
  40   { tasks, workerData } = { tasks: numberOfTasks, workerData: { proof: 'ok' } }
  41 ) {
  42   return runPoolifierTest(fixedPoolLessRecentlyUsed, { tasks, workerData })
  43 }
  44
  45 async function fixedClusterTestWeightedRoundRobin (
  46   { tasks, workerData } = { tasks: numberOfTasks, workerData: { proof: 'ok' } }
  47 ) {
  48   return runPoolifierTest(fixedPoolWeightedRoundRobin, { tasks, workerData })
  49 }
  50
  51 async function fixedClusterTestFairShare (
  52   { tasks, workerData } = { tasks: numberOfTasks, workerData: { proof: 'ok' } }
  53 ) {
  54   return runPoolifierTest(fixedPoolFairShare, { tasks, workerData })
  55 }
  56
  57 module.exports = {
  58   fixedClusterTest,
  59   fixedClusterTestLessRecentlyUsed,
  60   fixedClusterTestWeightedRoundRobin,
  61   fixedClusterTestFairShare
  62 }