Package ai.djl.serving.wlm

Class WorkerThread<I,O>

java.lang.Object
ai.djl.serving.wlm.WorkerThread<I,O>
All Implemented Interfaces:
Runnable
public final class WorkerThread<I,O> extends Object implements Runnable
The WorkerThread is the worker managed by the WorkLoadManager.

  • Method Details

    • run

      public void run()
      Specified by:
      run in interface Runnable

    • getWorkerId

      public String getWorkerId()
      Returns the worker thread ID.
      Returns:
      the worker thread ID

    • getWorkerIdNum

      public int getWorkerIdNum()
      Returns the worker thread ID (number without prefix).
      Returns:
      the worker thread ID (number without prefix)

    • getThreadType

      public WorkerPoolConfig.ThreadConfig<I,O> getThreadType()
      Returns the WorkerPoolConfig's WorkerPoolConfig.ThreadConfig for this thread.
      Returns:
      the WorkerPoolConfig's WorkerPoolConfig.ThreadConfig for this thread

    • isRunning

      public boolean isRunning()
      Returns true if the worker thread is running.
      Returns:
      true if the worker thread is running

    • getDevice

      public ai.djl.Device getDevice()
      Returns the device used by the thread.
      Returns:
      the device used by the thread

    • getStartTime

      public long getStartTime()
      Returns the thread start time.
      Returns:
      the thread start time

    • getState

      public WorkerState getState()
      Returns the worker state.
      Returns:
      the worker state

    • shutdown

      public void shutdown(WorkerState state)
      Shuts down the worker thread.
      Parameters:
      state - the state to set the thread to

    • addConfigJob

      public void addConfigJob(WorkerJob<I,O> wj)
      Adds a configuration job to this thread.
      Parameters:
      wj - the configuration job to add

    • isFixPoolThread

      public boolean isFixPoolThread()
      check if this worker is instantiate is one of the fix threads of a pool. fix threads are not automatically scales down, so they are candidate for down scaling when minWorker/maxWorker size of a model changes.
      Returns:
      the fixPoolThread

    • builder

      public static <I, O> WorkerThread.Builder<I,O> builder(WorkerPoolConfig<I,O> wpc)
      Creates a builder to build a WorkerThread.
      Type Parameters:
      I - the workerPoolConfig input class
      O - the workerPoolConfig output class
      Parameters:
      wpc - the WorkerPoolConfig the thread will be responsible for
      Returns:
      a new builder