}
JSON.stringify(o)
}
+ return { ok: 1 }
}
/**
fs.readFileSync(filePath, 'utf8')
}
fs.rmSync(baseDirectory, { recursive: true })
+ return { ok: 1 }
}
export const executeWorkerFunction = data => {
switch (workerType) {
case WorkerTypes.thread:
return new DynamicThreadPool(
- poolSize / 2,
- poolSize * 3,
+ Math.floor(poolSize / 2),
+ poolSize,
'./benchmarks/internal/thread-worker.mjs',
poolOptions
)
case WorkerTypes.cluster:
return new DynamicClusterPool(
- poolSize / 2,
- poolSize * 3,
+ Math.floor(poolSize / 2),
+ poolSize,
'./benchmarks/internal/cluster-worker.mjs',
poolOptions
)