FixedThreadPool | poolifier

X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FFixedThreadPool.html;h=6179daf6735a2a7ef010e26a3b3eae7b3811e41c;hb=29527e83440c324c4a78154ceba4c1076908f5d7;hp=38e5f6684eea18148b13d7f6344f3747957913aa;hpb=2041f3d8b2564bfab8e30db6a87dba283219ca86;p=poolifier.git diff --git a/docs/classes/FixedThreadPool.html b/docs/classes/FixedThreadPool.html index 38e5f668..6179daf6 100644 --- a/docs/classes/FixedThreadPool.html +++ b/docs/classes/FixedThreadPool.html @@ -1,13 +1,13 @@ -FixedThreadPool | poolifier - v2.6.40

@@ -45,19 +45,19 @@

DynamicThreadPool

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

Index

busy full info maxSize @@ -80,37 +80,43 @@

Constructors

constructor

new FixedThreadPool<Data, Response>(numberOfThreads, filePath, opts?): FixedThreadPool<Data, Response>
@@ -129,20 +135,23 @@
numberOfThreads: number

Number of threads for this pool.
-

filePath: string

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

opts: ThreadPoolOptions = {}

Options for this fixed thread pool.

+ +

Returns FixedThreadPool<Data, Response>

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

Properties

@@ -163,7 +172,7 @@

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

`Protected` `Readonly` filePath

filePath: string

@@ -172,7 +181,7 @@

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

`Protected` `Optional` `Readonly` max

max?: number

@@ -181,7 +190,7 @@

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

`Protected` `Readonly` numberOfWorkers

numberOfWorkers: number

@@ -190,7 +199,7 @@

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

`Protected` `Readonly` opts

opts: ThreadPoolOptions = {}

@@ -199,11 +208,11 @@

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>

@@ -222,7 +231,7 @@

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

`Readonly` `Internal` workerNodes

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

@@ -231,7 +240,7 @@

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

Accessors

@@ -246,7 +255,7 @@

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

`Protected` full

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

info

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

`Protected` maxSize

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

`Protected` minSize

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

`Private` ready

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

`Protected` type

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

`Private` utilization

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

`Protected` worker

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

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 AbstractPool.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 AbstractPool.checkDynamicPoolSize
-
- Defined in src/pools/abstract-pool.ts:185

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
+
+
Overrides AbstractPool.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

getWorkerInfo(workerNodeKey): undefined | WorkerInfo
getWorkerInfo(workerNodeKey): WorkerInfo
Gets the worker information given its worker node key.

@@ -580,13 +656,35 @@ Can be overridden.
workerNodeKey: number

The worker node key.
-

Returns undefined | WorkerInfo

The worker information.

+ +

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 AbstractPool.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 AbstractPool.listTaskFunctions
+
Inherited from AbstractPool.listTaskFunctionNames
+
- 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
+
+
Overrides AbstractPool.registerOnceWorkerMessageListener
- Defined in src/pools/abstract-pool.ts:724

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 AbstractPool.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 AbstractPool.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 AbstractPool.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

numberOfThreads: number

filePath: string

opts: ThreadPoolOptions = {}

Returns FixedThreadPool<Data, Response>

Properties

Protected Readonly filePath

Protected Optional 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[]

Returns Promise<Response>

`Protected` `Readonly` filePath

`Protected` `Optional` `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