Class ResourceManager

Resource manager that monitors memory, CPU and worker pool usage to prevent system overload, with automatic throttling when resources are constrained.

Implements

ResourceManager

Index

Constructors

Methods

canProceed canRestartWorker clearWorkerData getLimits getTotalWorkerMemory getUsage getWorkerMemoryStats recordWorkerCrash requestGC setLimits shouldRecycleWorker shouldThrottle trackWorkerMemory updateQueueSize updateWorkerCounts

Constructors

constructor

new ResourceManager(limits?: ResourceLimits): ResourceManager
Parameters
- Optionallimits: ResourceLimits
Returns ResourceManager

Methods

canProceed

canProceed(estimatedMemory?: number): boolean
Check if operation is safe to proceed
Parameters
- OptionalestimatedMemory: number
Returns boolean
Implementation of IResourceManager.canProceed

canRestartWorker

canRestartWorker(workerId: number): boolean
Check if worker can be restarted after crash
Parameters
- workerId: number
Returns boolean
Implementation of IResourceManager.canRestartWorker

clearWorkerData

clearWorkerData(workerId: number): void
Clear worker tracking data (called when worker is terminated)
Parameters
- workerId: number
Returns void

getLimits

getLimits(): Required<ResourceLimits>
Get resource limits

Returns Required<ResourceLimits>

getTotalWorkerMemory

getTotalWorkerMemory(): number
Get total worker memory usage

Returns number

getUsage

getUsage(): ResourceUsage
Get current resource usage

Returns ResourceUsage
Implementation of IResourceManager.getUsage

getWorkerMemoryStats

getWorkerMemoryStats(): Map<number, number>
Get per-worker memory statistics

Returns Map<number, number>

recordWorkerCrash

recordWorkerCrash(workerId: number): void
Record worker crash for restart strategy
Parameters
- workerId: number
Returns void
Implementation of IResourceManager.recordWorkerCrash

requestGC

requestGC(): void
Request garbage collection hint

Returns void
Implementation of IResourceManager.requestGC

setLimits

setLimits(limits: ResourceLimits): void
Configure resource limits
Parameters
- limits: ResourceLimits
Returns void
Implementation of IResourceManager.setLimits

shouldRecycleWorker

shouldRecycleWorker(workerId: number): boolean
Check if worker should be recycled due to memory pressure
Parameters
- workerId: number
Returns boolean
Implementation of IResourceManager.shouldRecycleWorker

shouldThrottle

shouldThrottle(): boolean
Check if throttling is needed

Returns boolean

trackWorkerMemory

trackWorkerMemory(workerId: number, heapUsed: number): void
Track worker memory usage
Parameters
- workerId: number
- heapUsed: number
Returns void
Implementation of IResourceManager.trackWorkerMemory

updateQueueSize

updateQueueSize(size: number): void
Update queue size
Parameters
- size: number
Returns void

updateWorkerCounts

updateWorkerCounts(active: number, idle: number): void
Update worker counts
Parameters
- active: number
- idle: number
Returns void