[poolifier.git] / benchmarks / internal / cluster-worker.mjs

import { isMaster } from 'cluster'
import { ClusterWorker } from '../../lib/index.mjs'
import { executeTaskFunction } from '../benchmarks-utils.mjs'
import { TaskFunctions } from '../benchmarks-types.mjs'

const debug = false

const taskFunction = data => {
  data = data || {}
  data.function = data.function || TaskFunctions.jsonIntegerSerialization
  const res = executeTaskFunction(data)
  debug === true && console.debug('This is the main thread ' + isMaster)
  return res
}

export default new ClusterWorker(taskFunction)
Commit	Line	Data
	1	import { isMaster } from 'cluster'
	2	import { ClusterWorker } from '../../lib/index.mjs'
	3	import { executeTaskFunction } from '../benchmarks-utils.mjs'
	4	import { TaskFunctions } from '../benchmarks-types.mjs'
	5
	6	const debug = false
	7
	8	const taskFunction = data => {
	9	data = data \|\| {}
	10	data.function = data.function \|\| TaskFunctions.jsonIntegerSerialization
	11	const res = executeTaskFunction(data)
	12	debug === true && console.debug('This is the main thread ' + isMaster)
	13	return res
	14	}
	15
	16	export default new ClusterWorker(taskFunction)