Package io.deephaven.engine.table.impl.util

Class UpdateGraphJobScheduler

java.lang.Object

io.deephaven.engine.table.impl.util.UpdateGraphJobScheduler

All Implemented Interfaces:

JobScheduler

public class UpdateGraphJobScheduler
extends Object
implements JobScheduler

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.util.JobScheduler

JobScheduler.IterateAction<CONTEXT_TYPE extends JobScheduler.JobThreadContext>, JobScheduler.IterateResumeAction<CONTEXT_TYPE extends JobScheduler.JobThreadContext>, JobScheduler.IterationManager<CONTEXT_TYPE extends JobScheduler.JobThreadContext>, JobScheduler.JobThreadContext

Field Summary

Fields inherited from interface io.deephaven.engine.table.impl.util.JobScheduler

DEFAULT_CONTEXT, DEFAULT_CONTEXT_FACTORY

Constructor Summary

Constructors

Constructor	Description
UpdateGraphJobScheduler()
UpdateGraphJobScheduler(@NotNull UpdateGraph updateGraph)

Method Summary

Modifier and Type	Method	Description
BasePerformanceEntry	getAccumulatedPerformance()	The performance statistics of all runnables that have been completed off-thread, or null if all were executed in the current thread.
void	submit(ExecutionContext executionContext, Runnable runnable, LogOutputAppendable description, Consumer<Exception> onError)	Cause runnable to be executed.
int	threadCount()	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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.deephaven.engine.table.impl.util.JobScheduler

iterateParallel, iterateParallel, iterateSerial

Constructor Details

UpdateGraphJobScheduler

public UpdateGraphJobScheduler(@NotNull
 @NotNull UpdateGraph updateGraph)

UpdateGraphJobScheduler

public UpdateGraphJobScheduler()

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