Class OperationInitializerJobScheduler

java.lang.Object
io.deephaven.engine.table.impl.util.OperationInitializerJobScheduler
All Implemented Interfaces:
JobScheduler

public class OperationInitializerJobScheduler extends Object implements JobScheduler
  • Constructor Details

    • OperationInitializerJobScheduler

      public OperationInitializerJobScheduler(@NotNull @NotNull OperationInitializer operationInitializer)
    • OperationInitializerJobScheduler

      public OperationInitializerJobScheduler()
  • Method Details

    • submit

      public void submit(ExecutionContext executionContext, Runnable runnable, LogOutputAppendable description, Consumer<Exception> onError)
      Description copied from interface: JobScheduler
      Cause runnable to be executed.
      Specified by:
      submit in interface JobScheduler
      Parameters:
      executionContext - the execution context to run it under
      runnable - the runnable to execute
      description - a description for logging
      onError - a routine to call if an exception occurs while running runnable
    • getAccumulatedPerformance

      public BasePerformanceEntry getAccumulatedPerformance()
      Description copied from interface: JobScheduler
      The performance statistics of all runnables that have been completed off-thread, or null if all were executed in the current thread.
      Specified by:
      getAccumulatedPerformance in interface JobScheduler
    • threadCount

      public int threadCount()
      Description copied from interface: JobScheduler
      How many threads exist in the job scheduler? The job submitters can use this value to determine how many sub-jobs to split work into.
      Specified by:
      threadCount in interface JobScheduler