repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add protected removeWorker member function (#124)
[poolifier.git]
/
src
/
pools
/
cluster
/
dynamic.ts
diff --git
a/src/pools/cluster/dynamic.ts
b/src/pools/cluster/dynamic.ts
index f2375a02d6e1babf875d27b40f01782849828af0..25940ad84340f43f3e7b0abf5cec7ddf3edbc8d4 100644
(file)
--- a/
src/pools/cluster/dynamic.ts
+++ b/
src/pools/cluster/dynamic.ts
@@
-1,5
+1,5
@@
import type { Worker } from 'cluster'
import type { Worker } from 'cluster'
-import type { MessageValue } from '../../utility-types'
+import type {
JSONValue,
MessageValue } from '../../utility-types'
import type { ClusterPoolOptions } from './fixed'
import { FixedClusterPool } from './fixed'
import type { ClusterPoolOptions } from './fixed'
import { FixedClusterPool } from './fixed'
@@
-13,10
+13,8
@@
import { FixedClusterPool } from './fixed'
* @since 2.0.0
*/
export class DynamicClusterPool<
* @since 2.0.0
*/
export class DynamicClusterPool<
- // eslint-disable-next-line @typescript-eslint/no-explicit-any
- Data = any,
- // eslint-disable-next-line @typescript-eslint/no-explicit-any
- Response = any
+ Data extends JSONValue = JSONValue,
+ Response extends JSONValue = JSONValue
> extends FixedClusterPool<Data, Response> {
/**
* @param min Min number of workers that will be always active
> extends FixedClusterPool<Data, Response> {
/**
* @param min Min number of workers that will be always active
@@
-56,10
+54,7
@@
export class DynamicClusterPool<
if (message.kill) {
this.sendToWorker(worker, { kill: 1 })
void this.destroyWorker(worker)
if (message.kill) {
this.sendToWorker(worker, { kill: 1 })
void this.destroyWorker(worker)
- // clean workers from data structures
- const workerIndex = this.workers.indexOf(worker)
- this.workers.splice(workerIndex, 1)
- this.tasks.delete(worker)
+ this.removeWorker(worker)
}
})
return worker
}
})
return worker