repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
perf: take into account the number of run tasks in LRU worker choice
[poolifier.git]
/
src
/
pools
/
abstract-pool.ts
diff --git
a/src/pools/abstract-pool.ts
b/src/pools/abstract-pool.ts
index 363db0e3f9b64ff650a0c351de05135c8de1de96..b3ebc19483d95e7c5f9863870e85823f976de157 100644
(file)
--- a/
src/pools/abstract-pool.ts
+++ b/
src/pools/abstract-pool.ts
@@
-165,14
+165,17
@@
export abstract class AbstractPool<
/** {@inheritDoc} */
public getWorkerRunningTasks (worker: Worker): number | undefined {
/** {@inheritDoc} */
public getWorkerRunningTasks (worker: Worker): number | undefined {
- return this.workers.get(this.getWorkerKey(worker) as number)?.tasksUsage
- ?.running
+ return this.getWorkerTasksUsage(worker)?.running
+ }
+
+ /** {@inheritDoc} */
+ public getWorkerRunTasks (worker: Worker): number | undefined {
+ return this.getWorkerTasksUsage(worker)?.run
}
/** {@inheritDoc} */
public getWorkerAverageTasksRunTime (worker: Worker): number | undefined {
}
/** {@inheritDoc} */
public getWorkerAverageTasksRunTime (worker: Worker): number | undefined {
- return this.workers.get(this.getWorkerKey(worker) as number)?.tasksUsage
- ?.avgRunTime
+ return this.getWorkerTasksUsage(worker)?.avgRunTime
}
/** {@inheritDoc} */
}
/** {@inheritDoc} */