repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
refactor: cleanup Map iteration
[poolifier.git]
/
src
/
pools
/
abstract-pool.ts
diff --git
a/src/pools/abstract-pool.ts
b/src/pools/abstract-pool.ts
index 01e621c297a1bc0cb818b807d1e13fe33344952e..199344067013c0b06169b53287d1848eb42e58cd 100644
(file)
--- a/
src/pools/abstract-pool.ts
+++ b/
src/pools/abstract-pool.ts
@@
-624,13
+624,13
@@
export abstract class AbstractPool<
}
private setTaskStealing (): void {
}
private setTaskStealing (): void {
- for (const
[workerNodeKey] of this.workerNodes.entrie
s()) {
+ for (const
workerNodeKey of this.workerNodes.key
s()) {
this.workerNodes[workerNodeKey].on('idle', this.handleWorkerNodeIdleEvent)
}
}
private unsetTaskStealing (): void {
this.workerNodes[workerNodeKey].on('idle', this.handleWorkerNodeIdleEvent)
}
}
private unsetTaskStealing (): void {
- for (const
[workerNodeKey] of this.workerNodes.entrie
s()) {
+ for (const
workerNodeKey of this.workerNodes.key
s()) {
this.workerNodes[workerNodeKey].off(
'idle',
this.handleWorkerNodeIdleEvent
this.workerNodes[workerNodeKey].off(
'idle',
this.handleWorkerNodeIdleEvent
@@
-639,7
+639,7
@@
export abstract class AbstractPool<
}
private setTasksStealingOnBackPressure (): void {
}
private setTasksStealingOnBackPressure (): void {
- for (const
[workerNodeKey] of this.workerNodes.entrie
s()) {
+ for (const
workerNodeKey of this.workerNodes.key
s()) {
this.workerNodes[workerNodeKey].on(
'backPressure',
this.handleWorkerNodeBackPressureEvent
this.workerNodes[workerNodeKey].on(
'backPressure',
this.handleWorkerNodeBackPressureEvent
@@
-648,7
+648,7
@@
export abstract class AbstractPool<
}
private unsetTasksStealingOnBackPressure (): void {
}
private unsetTasksStealingOnBackPressure (): void {
- for (const
[workerNodeKey] of this.workerNodes.entrie
s()) {
+ for (const
workerNodeKey of this.workerNodes.key
s()) {
this.workerNodes[workerNodeKey].off(
'backPressure',
this.handleWorkerNodeBackPressureEvent
this.workerNodes[workerNodeKey].off(
'backPressure',
this.handleWorkerNodeBackPressureEvent
@@
-791,7
+791,7
@@
export abstract class AbstractPool<
}
}
}
}
}
}
- for (const
[workerNodeKey] of this.workerNodes.entrie
s()) {
+ for (const
workerNodeKey of this.workerNodes.key
s()) {
this.registerWorkerMessageListener(
workerNodeKey,
taskFunctionOperationsListener
this.registerWorkerMessageListener(
workerNodeKey,
taskFunctionOperationsListener
@@
-1964,7
+1964,7
@@
export abstract class AbstractPool<
}
private flushTasksQueues (): void {
}
private flushTasksQueues (): void {
- for (const
[workerNodeKey] of this.workerNodes.entrie
s()) {
+ for (const
workerNodeKey of this.workerNodes.key
s()) {
this.flushTasksQueue(workerNodeKey)
}
}
this.flushTasksQueue(workerNodeKey)
}
}