Commit | Line | Data |
---|---|---|
ab7bb4f8 | 1 | const { isPrimary } = require('node:cluster') |
d35e5717 JB |
2 | const { ClusterWorker } = require('../../lib/index.cjs') |
3 | const { executeTaskFunction } = require('../benchmarks-utils.cjs') | |
4 | const { TaskFunctions } = require('../benchmarks-types.cjs') | |
57df5469 | 5 | |
041dc05b | 6 | const taskFunction = data => { |
2d2e32c2 | 7 | data = data || {} |
66566c5d | 8 | data.function = data.function || TaskFunctions.factorial |
f1c674cd | 9 | data.debug = data.debug || false |
dbca3be9 | 10 | const res = executeTaskFunction(data) |
f1c674cd | 11 | data.debug === true && console.debug(`This is the main thread ${isPrimary}`) |
30b963d4 | 12 | return res |
106744f7 | 13 | } |
14 | ||
ab7bb4f8 | 15 | module.exports = new ClusterWorker(taskFunction) |