Class ExecutorTableDataRefreshService
java.lang.Object
io.deephaven.engine.table.impl.locations.util.ExecutorTableDataRefreshService
- All Implemented Interfaces:
TableDataRefreshService
TableDataRefreshService
implementation that uses a ScheduledThreadPoolExecutor
.-
Nested Class Summary
Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.locations.util.TableDataRefreshService
TableDataRefreshService.CancellableSubscriptionToken, TableDataRefreshService.Helper, TableDataRefreshService.Null
-
Constructor Summary
ConstructorDescriptionExecutorTableDataRefreshService
(@NotNull String name, long tableLocationProviderRefreshIntervalMillis, long tableLocationRefreshIntervalMillis, int threadPoolSize) -
Method Summary
Modifier and TypeMethodDescriptionscheduleTableLocationProviderRefresh
(@NotNull AbstractTableLocationProvider tableLocationProvider) Schedule run for an AbstractTableLocationProvider.scheduleTableLocationRefresh
(@NotNull AbstractTableLocation tableLocation) Schedule run for an AbstractTableLocation.void
submitOneTimeAsyncTask
(@NotNull Runnable task) Submit a one-time task to be run asynchronously.
-
Constructor Details
-
ExecutorTableDataRefreshService
public ExecutorTableDataRefreshService(@NotNull @NotNull String name, long tableLocationProviderRefreshIntervalMillis, long tableLocationRefreshIntervalMillis, int threadPoolSize)
-
-
Method Details
-
submitOneTimeAsyncTask
Description copied from interface:TableDataRefreshService
Submit a one-time task to be run asynchronously.- Specified by:
submitOneTimeAsyncTask
in interfaceTableDataRefreshService
- Parameters:
task
- The task to run
-
scheduleTableLocationProviderRefresh
public TableDataRefreshService.CancellableSubscriptionToken scheduleTableLocationProviderRefresh(@NotNull @NotNull AbstractTableLocationProvider tableLocationProvider) Description copied from interface:TableDataRefreshService
Schedule run for an AbstractTableLocationProvider.- Specified by:
scheduleTableLocationProviderRefresh
in interfaceTableDataRefreshService
- Parameters:
tableLocationProvider
- The table location provider- Returns:
- A subscription token to be used for matching, which also supports cancellation
-
scheduleTableLocationRefresh
public TableDataRefreshService.CancellableSubscriptionToken scheduleTableLocationRefresh(@NotNull @NotNull AbstractTableLocation tableLocation) Description copied from interface:TableDataRefreshService
Schedule run for an AbstractTableLocation.- Specified by:
scheduleTableLocationRefresh
in interfaceTableDataRefreshService
- Parameters:
tableLocation
- The table location- Returns:
- A subscription token to be used for matching, which also supports cancellation
-