@morojs/moro / WorkerManager
Class: WorkerManager
Defined in: src/core/workers/worker-manager.ts:84
Worker Thread Manager Manages a pool of worker threads for CPU-intensive operations
Constructors
Constructor
new WorkerManager(
options?):WorkerManager
Defined in: src/core/workers/worker-manager.ts:98
Parameters
options?
maxQueueSize?
number
maxRestartAttempts?
number
restartBackoffMs?
number
workerCount?
number
Returns
WorkerManager
Methods
executeTask()
executeTask<
T>(task):Promise<T>
Defined in: src/core/workers/worker-manager.ts:277
Execute a task on a worker thread
Type Parameters
T
T = any
Parameters
task
Returns
Promise<T>
getStats()
getStats():
object
Defined in: src/core/workers/worker-manager.ts:418
Get worker statistics
Returns
object
activeTasks
activeTasks:
number
isShuttingDown
isShuttingDown:
boolean
queuedTasks
queuedTasks:
number
workerCount
workerCount:
number
shutdown()
shutdown():
Promise<void>
Defined in: src/core/workers/worker-manager.ts:380
Shutdown all workers
Returns
Promise<void>