X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=docs%2Fclasses%2FThreadWorker.html;h=8b5d3d325dd55c13f829d6cf2400f48bc749cf70;hb=fbc22127e53d3ec0ecbd38ecea25fb92ebef50e7;hp=4ff3550b76eb39aa701efc6c18d4db1558578d65;hpb=94ab998f44abe7ed2184a0702c45621b06f5641f;p=poolifier.git diff --git a/docs/classes/ThreadWorker.html b/docs/classes/ThreadWorker.html index 4ff3550b..8b5d3d32 100644 --- a/docs/classes/ThreadWorker.html +++ b/docs/classes/ThreadWorker.html @@ -1,4 +1,4 @@ -ThreadWorker | poolifier
+ThreadWorker | poolifier
-
+
  • poolifier
    • @@ -30,21 +30,21 @@ but the minimum number of workers will be guaranteed.

    Type Parameters

    • -

      Data = unknown

      +

      Data = unknown

      Type of data this worker receives from pool's execution. This can only be serializable data.

    • -

      Response = unknown

      +

      Response = unknown

      Type of response the worker sends back to the main thread. This can only be serializable data.

    Hierarchy

      -
    • AbstractWorker<MessagePort, Data, Response> +
    • AbstractWorker<MessagePort, Data, Response>
      • ThreadWorker
    +
  • Defined in src/worker/thread-worker.ts:21
@@ -52,38 +52,38 @@ but the minimum number of workers will be guaranteed.

Constructors

-
constructor +
constructor

Properties

-
aliveInterval? -isMain -lastTaskTimestamp -mainWorker -opts +
aliveInterval? +isMain +lastTaskTimestamp +mainWorker +opts

Methods

-
asyncId -bind -checkAlive -emitDestroy -getMainWorker -handleError -messageListener -run -runAsync -runInAsyncScope -sendToMainWorker -triggerAsyncId -bind +
asyncId +bind +checkAlive +emitDestroy +getMainWorker +handleError +messageListener +run +runAsync +runInAsyncScope +sendToMainWorker +triggerAsyncId +bind

Constructors

-
+

constructor

-
    - +
      +

    • Constructs a new poolifier thread worker.

      @@ -91,95 +91,84 @@ but the minimum number of workers will be guaranteed.

      Type Parameters

      • -

        Data = unknown

        • +

        Data = unknown

      • -

        Response = unknown

+

Response = unknown

Parameters

  • -
    fn: ((data: Data) => Response)
    +
    fn: WorkerFunction<Data, Response>

    Function processed by the worker when the pool's execution function is invoked.

    -
    -
      -
    • -
        -
      • (data: Data): Response
        • -
      • -
        -

        Parameters

        -
          -
        • -
          data: Data
        -

        Returns Response

    • +
  • -
    opts: WorkerOptions = {}
    +
    opts: WorkerOptions = {}

    Options for the worker.

    • -

    Returns ThreadWorker<Data, Response>

    Properties

    -
    +

    Protected Optional Readonly aliveInterval

    -
    aliveInterval?: Timeout
    +
    aliveInterval?: Timeout

    Handler id of the aliveInterval worker alive check.

    -
    +
  • Defined in src/worker/abstract-worker.ts:36
    • +

    Protected Readonly isMain

    -
    isMain: boolean
    +
    isMain: boolean

    Whether this is the main worker or not.

    -
    +
  • Defined in src/worker/abstract-worker.ts:48
    • +

    Protected lastTaskTimestamp

    -
    lastTaskTimestamp: number
    +
    lastTaskTimestamp: number

    Timestamp of the last task processed by this worker.

    -
    +
  • Defined in src/worker/abstract-worker.ts:32
    • +

    Protected mainWorker

    -
    mainWorker: undefined | null | MessagePort
    +
    mainWorker: undefined | null | MessagePort

    Reference to main worker.

    -
    +
  • Defined in src/worker/abstract-worker.ts:50
    • +

    Protected Readonly opts

    -
    opts: WorkerOptions = ...
    +
    opts: WorkerOptions = ...

    Options for the worker.

    +
  • Defined in src/worker/abstract-worker.ts:51

    • Methods

    -
    +

    asyncId

    -
      - +
        +

      • Returns

        The unique asyncId assigned to the resource.

        Returns number

    -
    +

    bind

    -
      - +
        +

      • Binds the given function to execute to this AsyncResource's scope.

        The returned function will have an asyncResource property referencing @@ -191,33 +180,33 @@ the AsyncResource to which the function is bound.

        Type Parameters

        • -

          Func extends ((...args: any[]) => any)

    +

    Func extends ((...args) => any)

    Parameters

    • -
      fn: Func
      +
      fn: Func

      The function to bind to the current AsyncResource.

    -

    Returns Func & {
        asyncResource: AsyncResource;
    }

    -
    +

    Protected checkAlive

    -
    -
    +
  • Defined in src/worker/abstract-worker.ts:156
    • +

    emitDestroy

    -
      - +
        +

      • Call all destroy hooks. This should only ever be called once. An error will be thrown if it is called more than once. This must be manually called. If @@ -226,27 +215,27 @@ never be called.

        Returns

        A reference to asyncResource.

        -

        Returns ThreadWorker<Data, Response>

    -
    +

    Protected getMainWorker

    -
      - +
    -
    +
  • Defined in src/worker/abstract-worker.ts:139
    • +

    Protected handleError

    -
      - +
        +

      • Handles an error and convert it to a string so it can be sent back to the main worker.

        @@ -256,17 +245,17 @@ never be called.

        Parameters

        • -
          e: string | Error
          +
          e: string | Error

          The error raised by the worker.

        Returns string

    -
    +
  • Defined in src/worker/abstract-worker.ts:171
    • +

    Protected messageListener

    -
      - +
        +

      • Worker message listener.

        @@ -274,32 +263,21 @@ never be called.

        Parameters

        • -
          message: MessageValue<Data, MessagePort>
          +
          message: MessageValue<Data, MessagePort>

          Message received.

        • -
          fn: ((data: Data) => Response)
          +
          fn: WorkerFunction<Data, Response>

          Function processed by the worker when the pool's execution function is invoked.

          -
          -
            -
          • -
              -
            • (data: Data): Response
              • -
            • -
              -

              Parameters

              -
                -
              • -
                data: Data
              -

              Returns Response

    +

    Returns void

    -
    +
  • Defined in src/worker/abstract-worker.ts:89
    • +

    Protected run

    -
    -
    +
  • Defined in src/worker/abstract-worker.ts:181
    • +

    Protected runAsync

    -
    -
    +
  • Defined in src/worker/abstract-worker.ts:208
    • +

    runInAsyncScope

    -
    +

    Result

    Parameters

    +

    Returns Result

  • -
    Optional thisArg: This
    +
    Optional thisArg: This

    The receiver to be used for the function call.

  • -
    Rest ...args: any[]
    +
    Rest ...args: any[]

    Optional arguments to pass to the function.

    • -

    Returns Result

    +

    triggerAsyncId

    -
    -
    +

    Static bind

    -
      - +
        +

      • Binds the given function to the current execution context.

        The returned function will have an asyncResource property referencing @@ -456,30 +414,31 @@ the AsyncResource to which the function is bound.

        Type Parameters

        • -

          Func extends ((this: ThisArg, ...args: any[]) => any)

          • +

          Func extends ((this, ...args) => any)

        • -

          ThisArg

    +

    ThisArg

    Parameters

    -

    Returns Func & {
        asyncResource: AsyncResource;
    }