repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
refactor: use simple quote in error string
[poolifier.git]
/
src
/
pools
/
selection-strategies
/
worker-choice-strategy-context.ts
diff --git
a/src/pools/selection-strategies/worker-choice-strategy-context.ts
b/src/pools/selection-strategies/worker-choice-strategy-context.ts
index acfee48adf0986d28e3209329cfc9a0b4aa8e158..21c24f7c63799561f1b32e17ebda121b5a2464d3 100644
(file)
--- a/
src/pools/selection-strategies/worker-choice-strategy-context.ts
+++ b/
src/pools/selection-strategies/worker-choice-strategy-context.ts
@@
-2,8
+2,8
@@
import { DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS } from '../../utils'
import type { IPool } from '../pool'
import type { IWorker } from '../worker'
import { FairShareWorkerChoiceStrategy } from './fair-share-worker-choice-strategy'
import type { IPool } from '../pool'
import type { IWorker } from '../worker'
import { FairShareWorkerChoiceStrategy } from './fair-share-worker-choice-strategy'
-import { Le
ssBusyWorkerChoiceStrategy } from './less
-busy-worker-choice-strategy'
-import { Le
ssUsedWorkerChoiceStrategy } from './less
-used-worker-choice-strategy'
+import { Le
astBusyWorkerChoiceStrategy } from './least
-busy-worker-choice-strategy'
+import { Le
astUsedWorkerChoiceStrategy } from './least
-used-worker-choice-strategy'
import { RoundRobinWorkerChoiceStrategy } from './round-robin-worker-choice-strategy'
import type {
IWorkerChoiceStrategy,
import { RoundRobinWorkerChoiceStrategy } from './round-robin-worker-choice-strategy'
import type {
IWorkerChoiceStrategy,
@@
-56,15
+56,15
@@
export class WorkerChoiceStrategyContext<
)
],
[
)
],
[
- WorkerChoiceStrategies.LE
SS
_USED,
- new (Le
ss
UsedWorkerChoiceStrategy.bind(this))<Worker, Data, Response>(
+ WorkerChoiceStrategies.LE
AST
_USED,
+ new (Le
ast
UsedWorkerChoiceStrategy.bind(this))<Worker, Data, Response>(
pool,
opts
)
],
[
pool,
opts
)
],
[
- WorkerChoiceStrategies.LE
SS
_BUSY,
- new (Le
ss
BusyWorkerChoiceStrategy.bind(this))<Worker, Data, Response>(
+ WorkerChoiceStrategies.LE
AST
_BUSY,
+ new (Le
ast
BusyWorkerChoiceStrategy.bind(this))<Worker, Data, Response>(
pool,
opts
)
pool,
opts
)
@@
-131,7
+131,7
@@
export class WorkerChoiceStrategyContext<
* Executes the worker choice strategy algorithm in the context.
*
* @returns The key of the worker node.
* Executes the worker choice strategy algorithm in the context.
*
* @returns The key of the worker node.
- * @throws {@link
@node
/api/errors.html#class-error} If the worker node key is null or undefined.
+ * @throws {@link
https://nodejs.org
/api/errors.html#class-error} If the worker node key is null or undefined.
*/
public execute (): number {
const workerNodeKey = (
*/
public execute (): number {
const workerNodeKey = (
@@
-165,8
+165,8
@@
export class WorkerChoiceStrategyContext<
* @param opts - The worker choice strategy options.
*/
public setOptions (opts: WorkerChoiceStrategyOptions): void {
* @param opts - The worker choice strategy options.
*/
public setOptions (opts: WorkerChoiceStrategyOptions): void {
-
this.workerChoiceStrategies.forEach(workerChoiceStrategy =>
{
+
for (const workerChoiceStrategy of this.workerChoiceStrategies.values())
{
workerChoiceStrategy.setOptions(opts)
workerChoiceStrategy.setOptions(opts)
- }
)
+ }
}
}
}
}