java.lang.Object
java.lang.Thread
net.i2p.util.I2PThread
net.i2p.router.JobQueueRunner
All Implemented Interfaces:
Runnable
class JobQueueRunnerextends I2PThread
Worker thread that executes jobs from the router job queue. Handles job execution, timing collection, error handling, and performance monitoring for individual job processing threads.

  • Constructor Details

    • JobQueueRunner

      public JobQueueRunner(RouterContext context, int id)
      Create a new job queue runner.
      Parameters:
      context - the router context
      id - the runner id

  • Method Details

    • getCurrentJob

      public Job getCurrentJob()
      The job currently being executed.
      Returns:
      the current job

    • getLastJob

      public Job getLastJob()
      The most recently completed job.
      Returns:
      the last job

    • getRunnerId

      public int getRunnerId()
      Identifier for this runner.
      Returns:
      the runner id

    • stopRunning

      public void stopRunning()
      Stop the runner.

    • startRunning

      public void startRunning()
      Start the runner.

    • getLastBegin

      public long getLastBegin()
      Time the last job began.
      Returns:
      the time the last job began

    • getLastEnd

      public long getLastEnd()
      Time the last job ended.
      Returns:
      the time the last job ended

    • run

      public void run()
      Description copied from class: I2PThread
      Run the thread, catching and reporting OOM and other failures.
      Specified by:
      run in interface Runnable
      Overrides:
      run in class I2PThread