DynamicBatchedWorkerPool
chainalign-backend / services/dynamicBatchedWorkerPool / DynamicBatchedWorkerPool
Class: DynamicBatchedWorkerPool
Defined in: services/dynamicBatchedWorkerPool.js:3
Constructors
Constructor
new DynamicBatchedWorkerPool(
workerFile,minWorkers,maxWorkers,batchSize):DynamicBatchedWorkerPool
Defined in: services/dynamicBatchedWorkerPool.js:4
Parameters
workerFile
any
minWorkers
number = 2
maxWorkers
number = 8
batchSize
number = 3
Returns
DynamicBatchedWorkerPool
Properties
batchSize
batchSize:
number
Defined in: services/dynamicBatchedWorkerPool.js:8
maxWorkers
maxWorkers:
number
Defined in: services/dynamicBatchedWorkerPool.js:7
minWorkers
minWorkers:
number
Defined in: services/dynamicBatchedWorkerPool.js:6
taskQueue
taskQueue:
any[]
Defined in: services/dynamicBatchedWorkerPool.js:11
workerFile
workerFile:
any
Defined in: services/dynamicBatchedWorkerPool.js:5
workers
workers:
any[]
Defined in: services/dynamicBatchedWorkerPool.js:10
Methods
addWorker()
addWorker():
void
Defined in: services/dynamicBatchedWorkerPool.js:18
Returns
void
checkQueue()
checkQueue():
void
Defined in: services/dynamicBatchedWorkerPool.js:44
Returns
void
runTask()
runTask(
task,priority):Promise<any>
Defined in: services/dynamicBatchedWorkerPool.js:66
Parameters
task
any
priority
number = 0
Returns
Promise<any>
shutdown()
shutdown():
void
Defined in: services/dynamicBatchedWorkerPool.js:73
Returns
void