DynamicThreadPool | poolifier

X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FDynamicThreadPool.html;h=c03d97602875426e0db043c5929bac798b9e384e;hb=c11be5eddc7229e4b77105ed27e93697b65d0146;hp=bb763bd428bfba6636cc95af5c59f3b4fd415597;hpb=da7631f88ed580377ddba0882eac576bb32832eb;p=poolifier.git diff --git a/docs/classes/DynamicThreadPool.html b/docs/classes/DynamicThreadPool.html index bb763bd4..c03d9760 100644 --- a/docs/classes/DynamicThreadPool.html +++ b/docs/classes/DynamicThreadPool.html @@ -1,13 +1,13 @@ -DynamicThreadPool | poolifier - v2.6.41

@@ -45,19 +45,19 @@ When the maximum number of threads is reached and workers are busy, an event is

DynamicThreadPool

Defined in src/pools/thread/dynamic.ts:16

Index

Constructors

constructor +

constructor

Properties

emitter? +

emitter? filePath max numberOfWorkers @@ -68,7 +68,7 @@ When the maximum number of threads is reached and workers are busy, an event is

Accessors

busy +

busy full info maxSize @@ -80,37 +80,43 @@ When the maximum number of threads is reached and workers are busy, an event is

Constructors

constructor

new DynamicThreadPool<Data, Response>(min, max, filePath, opts?): DynamicThreadPool<Data, Response>
@@ -129,24 +135,28 @@ When the maximum number of threads is reached and workers are busy, an event is
min: number

Minimum number of threads which are always active.
-

max: number

Maximum number of threads that can be created by this pool.

filePath: string

Path to an implementation of a ThreadWorker file, which can be relative or absolute.

opts: ThreadPoolOptions = {}

Options for this dynamic thread pool.

+ +

Returns DynamicThreadPool<Data, Response>

Defined in src/pools/thread/dynamic.ts:28

Properties

@@ -167,7 +177,7 @@ When the maximum number of threads is reached and workers are busy, an event is

Defined in src/pools/abstract-pool.ts:73

`Protected` `Readonly` filePath

filePath: string

@@ -176,7 +186,7 @@ When the maximum number of threads is reached and workers are busy, an event is

Defined in src/pools/abstract-pool.ts:128

`Protected` `Readonly` max

max: number

@@ -185,7 +195,7 @@ When the maximum number of threads is reached and workers are busy, an event is

Defined in src/pools/thread/dynamic.ts:30

`Protected` `Readonly` numberOfWorkers

numberOfWorkers: number

@@ -194,7 +204,7 @@ When the maximum number of threads is reached and workers are busy, an event is

Defined in src/pools/abstract-pool.ts:127

`Protected` `Readonly` opts

opts: ThreadPoolOptions = {}

@@ -203,11 +213,11 @@ When the maximum number of threads is reached and workers are busy, an event is

Defined in src/pools/thread/fixed.ts:49

`Protected` promiseResponseMap

promiseResponseMap: Map<string, PromiseResponseWrapper<Response>> = ...

The task execution response promise map.

The task execution response promise map:

key: The message id of each submitted task.
value: An object that contains the worker, the execution response promise resolve and reject callbacks.

Defined in src/pools/abstract-pool.ts:82

`Protected` workerChoiceStrategyContext

workerChoiceStrategyContext: WorkerChoiceStrategyContext<Worker, Data, Response>

@@ -226,7 +236,7 @@ When the maximum number of threads is reached and workers are busy, an event is

Defined in src/pools/abstract-pool.ts:88

`Readonly` `Internal` workerNodes

workerNodes: IWorkerNode<Worker, Data>[] = []

@@ -235,7 +245,7 @@ When the maximum number of threads is reached and workers are busy, an event is

Defined in src/pools/abstract-pool.ts:70

Accessors

@@ -250,7 +260,7 @@ When the maximum number of threads is reached and workers are busy, an event is

Defined in src/pools/thread/dynamic.ts:44

Methods

addTaskFunction

addTaskFunction(name, fn): Promise<boolean>
+
Adds a task function to this pool. +If a task function with the same name already exists, it will be overwritten.
+
+
+
Parameters
+
- +
  name: string
  +
  The name of the task function.
  +
  +
- +
  fn: TaskFunction<Data, Response>
  +
  The task function.
  +
  +
+
Returns Promise<boolean>
true if the task function was added, false otherwise.
+ +
+
Throws
https://nodejs.org/api/errors.html#class-typeerror If the name parameter is not a string or an empty string.
+ +
Throws
https://nodejs.org/api/errors.html#class-typeerror If the fn parameter is not a function.
+
+
Inherited from FixedThreadPool.addTaskFunction
+
- Defined in src/pools/abstract-pool.ts:790

`Protected` afterTaskExecutionHook

workerNodeKey: number

The worker node key.
-

message: MessageValue<Response, unknown>

The received message.
-

+ +

Returns void

Defined in src/pools/abstract-pool.ts:1026

`Protected` afterWorkerNodeSetup

workerNodeKey: number

The newly created worker node key.
-

+ +

Returns void

Defined in src/pools/abstract-pool.ts:1337

`Protected` beforeTaskExecutionHook

workerNodeKey: number

The worker node key.
-

task: Task<Data>

The task to execute.
-

+ +

Returns void

`Protected` checkDynamicPoolSize

checkDynamicPoolSize(min, max): void
-
-
Parameters
-
- -
  min: number
- -
  max: number
-
Returns void
-
Inherited from FixedThreadPool.checkDynamicPoolSize
-
- Defined in src/pools/abstract-pool.ts:187

Defined in src/pools/abstract-pool.ts:996

`Protected` createAndSetupDynamicWorkerNode

Defined in src/pools/abstract-pool.ts:1243

`Protected` createAndSetupWorkerNode

Defined in src/pools/abstract-pool.ts:1199

`Protected` createWorker

Defined in src/pools/thread/fixed.ts:136

`Protected` deregisterWorkerMessageListener

deregisterWorkerMessageListener<Message>(workerNodeKey, listener): void
+
Deregisters a listener callback on the worker given its worker node key.
+
+
+
Type Parameters
+
- +
  Message
+
+
Parameters
+
- +
  workerNodeKey: number
  +
  The worker node key.
  +
  +
- +
  listener: ((message) => void)
  +
  The message listener callback.
  +
  +
  +
  - +
    - (message): void
    - +
      +
      Parameters
      +
      +
      +
      message: MessageValue<Message, unknown>
      +
      Returns void
+
Returns void
+
+
Inherited from FixedThreadPool.deregisterWorkerMessageListener
+
- Defined in src/pools/thread/fixed.ts:126

destroy

Defined in src/pools/abstract-pool.ts:934

`Protected` destroyWorkerNode

workerNodeKey: number

The worker node key.
-

+ +

Returns Promise<void>

Defined in src/pools/thread/fixed.ts:60

enableTasksQueue

enable: boolean

Whether to enable or disable the worker node tasks queue.
-

Optional tasksQueueOptions: TasksQueueOptions

The worker node tasks queue options.
-
Optional

+ +

Returns void

Defined in src/pools/abstract-pool.ts:559

execute

Optional data: Data

The optional task input data for the specified task function. This can only be structured-cloneable data.
-
Optional

Optional name: string

The optional name of the task function to execute. If not specified, the default task function will be executed.
-
Optional

Optional transferList: TransferListItem[]

An optional array of transferable objects to transfer ownership of. Ownership of the transferred objects is given to the pool's worker_threads worker and they should not be used in the main thread afterwards.
-
Optional

+ +

Returns Promise<Response>

Promise that will be fulfilled when the task is completed.

Defined in src/pools/abstract-pool.ts:864

`Protected` flushTasksQueue

Returns void

Defined in src/pools/abstract-pool.ts:1660

`Protected` getWorkerInfo

workerNodeKey: number

The worker node key.
-

+ +

Returns WorkerInfo

The worker information.

Defined in src/pools/abstract-pool.ts:1576

hasTaskFunction

hasTaskFunction(name): boolean
+
Whether the specified task function exists in this pool.
+
+
+
Parameters
+
- +
  name: string
  +
  The name of the task function.
  +
  +
+
Returns boolean
true if the task function exists, false otherwise.
+ +
+
Inherited from FixedThreadPool.hasTaskFunction
+
- Defined in src/pools/abstract-pool.ts:777

hasWorkerNodeBackPressure

workerNodeKey: number

The worker node key.
-

+ +

Returns boolean

true if the worker node has back pressure, false otherwise.

Defined in src/pools/abstract-pool.ts:1618

`Protected` internalBusy

Defined in src/pools/abstract-pool.ts:661

`Protected` isMain

listTaskFunctions

Defined in src/pools/thread/fixed.ts:55

listTaskFunctionNames

listTaskFunctions(): string[]
listTaskFunctionNames(): string[]
Lists the names of task function available in this pool.

Returns string[]
The names of task function available in this pool.
-
Inherited from FixedThreadPool.listTaskFunctions
+
Inherited from FixedThreadPool.listTaskFunctionNames
- Defined in src/pools/abstract-pool.ts:726

Defined in src/pools/abstract-pool.ts:829

`Protected` registerOnceWorkerMessageListener

registerOnceWorkerMessageListener<Message>(workerNodeKey, listener): void
+
Registers once a listener callback on the worker given its worker node key.
+
+
+
Type Parameters
+
- +
  Message
+
+
Parameters
+
- +
  workerNodeKey: number
  +
  The worker node key.
  +
  +
- +
  listener: ((message) => void)
  +
  The message listener callback.
  +
  +
  +
  - +
    - (message): void
    - +
      +
      Parameters
      +
      +
      +
      message: MessageValue<Message, unknown>
      +
      Returns void
+
Returns void
+
+
Inherited from FixedThreadPool.registerOnceWorkerMessageListener
+
- Defined in src/pools/thread/fixed.ts:116

`Protected` registerWorkerMessageListener

workerNodeKey: number

The worker node key.
-

listener: ((message) => void)

The message listener callback.

+

Defined in src/pools/thread/fixed.ts:106

removeTaskFunction

removeTaskFunction(name): Promise<boolean>
+
Removes a task function from this pool.
+
+
+
Parameters
+
- +
  name: string
  +
  The name of the task function.
  +
  +
+
Returns Promise<boolean>
true if the task function was removed, false otherwise.
+ +
+
Inherited from FixedThreadPool.removeTaskFunction
+
- Defined in src/pools/abstract-pool.ts:813

`Protected` sendKillMessageToWorker

sendKillMessageToWorker(workerNodeKey, workerId): Promise<void>
sendKillMessageToWorker(workerNodeKey): Promise<void>
Parameters
- -
  workerNodeKey: number
- -
  workerId: number
+
workerNodeKey: number

Returns Promise<void>

Defined in src/pools/abstract-pool.ts:944

`Protected` sendStartupMessageToWorker

workerNodeKey: number

The worker node key.
-

+ +

Returns void

Defined in src/pools/thread/fixed.ts:91

`Protected` sendToWorker

workerNodeKey: number

The worker node key.
-

message: MessageValue<Data, unknown>

The message.
-

Optional transferList: TransferListItem[]

The optional array of transferable objects.
-
Optional

+ +

Returns void

Defined in src/pools/thread/fixed.ts:77

setDefaultTaskFunction

setDefaultTaskFunction(name): Promise<boolean>
+
Sets the default task function in this pool.
+
+
+
Parameters
+
- +
  name: string
  +
  The name of the task function.
  +
  +
+
Returns Promise<boolean>
true if the default task function was set, false otherwise.
+ +
+
Inherited from FixedThreadPool.setDefaultTaskFunction
+
- Defined in src/pools/abstract-pool.ts:842

setTasksQueueOptions

tasksQueueOptions: TasksQueueOptions

The worker node tasks queue options.
-

+ +

Returns void

Defined in src/pools/abstract-pool.ts:573

setWorkerChoiceStrategy

workerChoiceStrategy: "ROUND_ROBIN" | "LEAST_USED" | "LEAST_BUSY" | "LEAST_ELU" | "FAIR_SHARE" | "WEIGHTED_ROUND_ROBIN" | "INTERLEAVED_WEIGHTED_ROUND_ROBIN"

The worker choice strategy.
-

Optional workerChoiceStrategyOptions: WorkerChoiceStrategyOptions

The worker choice strategy options.
-
Optional

+ +

Returns void

Defined in src/pools/abstract-pool.ts:526

setWorkerChoiceStrategyOptions

workerChoiceStrategyOptions: WorkerChoiceStrategyOptions

The worker choice strategy options.
-

+ +

Returns void

Defined in src/pools/abstract-pool.ts:545

`Protected` setupHook

Defined in src/pools/abstract-pool.ts:980

start

start(): void
+
Starts the minimum number of workers in this pool.
+
+
Returns void
+
+
Inherited from FixedThreadPool.start
+
- Defined in src/pools/abstract-pool.ts:918

`Protected` workerListener

Defined in src/pools/abstract-pool.ts:1488

Generated using TypeDoc

\ No newline at end of file +

\ No newline at end of file

Index

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

constructor

min: number

max: number

filePath: string

opts: ThreadPoolOptions = {}

Returns DynamicThreadPool<Data, Response>

Properties

Protected Readonly filePath

Protected Readonly max

Protected Readonly numberOfWorkers

Protected Readonly opts

Protected promiseResponseMap

Protected workerChoiceStrategyContext

Readonly Internal workerNodes

Accessors

Protected full

info

Protected maxSize

Protected minSize

Private ready

Protected type

Private utilization

Protected worker

Methods

addTaskFunction

Parameters

name: string

fn: TaskFunction<Data, Response>

Returns Promise<boolean>

Throws

Throws

Protected afterTaskExecutionHook

workerNodeKey: number

message: MessageValue<Response, unknown>

Returns void

Protected afterWorkerNodeSetup

workerNodeKey: number

Returns void

Protected beforeTaskExecutionHook

workerNodeKey: number

task: Task<Data>

Returns void

Protected checkDynamicPoolSize

Parameters

min: number

max: number

Returns void

Protected createAndSetupDynamicWorkerNode

Protected createAndSetupWorkerNode

Protected createWorker

Protected deregisterWorkerMessageListener

Type Parameters

Message

Parameters

workerNodeKey: number

listener: ((message) => void)

Parameters

message: MessageValue<Message, unknown>

Returns void

Returns void

destroy

Protected destroyWorkerNode

workerNodeKey: number

Returns Promise<void>

enableTasksQueue

enable: boolean

Optional tasksQueueOptions: TasksQueueOptions

Returns void

execute

Optional data: Data

Optional name: string

Optional transferList: TransferListItem[]

`Protected` `Readonly` filePath

`Protected` `Readonly` max

`Protected` `Readonly` numberOfWorkers

`Protected` `Readonly` opts

`Protected` promiseResponseMap

`Protected` workerChoiceStrategyContext

`Readonly` `Internal` workerNodes

`Protected` full

`Protected` maxSize

`Protected` minSize

`Private` ready

`Protected` type

`Private` utilization

`Protected` worker

`Protected` afterTaskExecutionHook

`Protected` afterWorkerNodeSetup

`Protected` beforeTaskExecutionHook

`Protected` checkDynamicPoolSize

`Protected` createAndSetupDynamicWorkerNode

`Protected` createAndSetupWorkerNode

`Protected` createWorker

`Protected` deregisterWorkerMessageListener

`Protected` destroyWorkerNode

`Optional` tasksQueueOptions: TasksQueueOptions

`Optional` data: Data

`Optional` name: string

`Optional` transferList: TransferListItem[]

`Protected` flushTasksQueue

`Protected` getWorkerInfo

`Protected` internalBusy

`Protected` isMain

`Protected` registerOnceWorkerMessageListener

`Protected` registerWorkerMessageListener

`Protected` sendKillMessageToWorker

`Protected` sendStartupMessageToWorker

`Protected` sendToWorker

`Optional` transferList: TransferListItem[]

`Optional` workerChoiceStrategyOptions: WorkerChoiceStrategyOptions

`Protected` setupHook

`Protected` workerListener