.scannerwork
*.bak
lib
+dist
reports/
benchmarks/internal/results/
.then(res => console.log(res))
.catch(err => console.error(err))
-setTimeout(pool.destroy.bind(pool), 3000)
+setTimeout(pool.destroy(pool), 3000)
this.checkNumberOfWorkers(this.numberOfWorkers)
this.checkFilePath(this.filePath)
this.checkPoolOptions(this.opts)
+
+ this.chooseWorker.bind(this)
+ this.internalExecute.bind(this)
+ this.checkAndEmitBusy.bind(this)
+ this.sendToWorker.bind(this)
+
this.setupHook()
for (let i = 1; i <= this.numberOfWorkers; i++) {
protected readonly pool: IPoolInternal<Worker, Data, Response>
) {
this.isDynamicPool = this.pool.type === PoolType.DYNAMIC
+ this.choose.bind(this)
}
/** {@inheritDoc} */
private readonly createWorkerCallback: () => number,
workerChoiceStrategy: WorkerChoiceStrategy = WorkerChoiceStrategies.ROUND_ROBIN
) {
+ this.execute.bind(this)
this.setWorkerChoiceStrategy(workerChoiceStrategy)
}