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

Class ExecutorTableDataRefreshService

java.lang.Object

io.deephaven.engine.table.impl.locations.util.ExecutorTableDataRefreshService

All Implemented Interfaces:

TableDataRefreshService

public class ExecutorTableDataRefreshService
extends Object
implements 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

Constructors

Constructor	Description
ExecutorTableDataRefreshService(@NotNull String name, long tableLocationProviderRefreshIntervalMillis, long tableLocationRefreshIntervalMillis, int threadPoolSize)

Method Summary

Modifier and Type	Method	Description
TableDataRefreshService.CancellableSubscriptionToken	scheduleTableLocationProviderRefresh(@NotNull AbstractTableLocationProvider tableLocationProvider)	Schedule run for an AbstractTableLocationProvider using an implementation-defined default refresh interval
TableDataRefreshService.CancellableSubscriptionToken	scheduleTableLocationProviderRefresh(@NotNull AbstractTableLocationProvider tableLocationProvider, long refreshIntervalMillis)	Schedule run for an AbstractTableLocationProvider.
TableDataRefreshService.CancellableSubscriptionToken	scheduleTableLocationRefresh(@NotNull AbstractTableLocation tableLocation)	Schedule run for an AbstractTableLocation using an implementation-defined default refresh interval
TableDataRefreshService.CancellableSubscriptionToken	scheduleTableLocationRefresh(@NotNull AbstractTableLocation tableLocation, long refreshIntervalMillis)	Schedule run for an AbstractTableLocation.
void	submitOneTimeAsyncTask(@NotNull Runnable task)	Submit a one-time task to be run asynchronously.

Methods inherited from class java.lang.Object

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

Constructor Details

ExecutorTableDataRefreshService

public ExecutorTableDataRefreshService(@NotNull
 @NotNull String name,
 long tableLocationProviderRefreshIntervalMillis,
 long tableLocationRefreshIntervalMillis,
 int threadPoolSize)

Method Details

submitOneTimeAsyncTask

public void submitOneTimeAsyncTask(@NotNull
 @NotNull Runnable task)

Description copied from interface: TableDataRefreshService

Submit a one-time task to be run asynchronously.

Specified by:

submitOneTimeAsyncTask in interface TableDataRefreshService

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 using an implementation-defined default refresh interval

Specified by:

scheduleTableLocationProviderRefresh in interface TableDataRefreshService

Parameters:

tableLocationProvider - The table location provider

Returns:

A subscription token to be used for matching, which also supports cancellation

scheduleTableLocationProviderRefresh

public TableDataRefreshService.CancellableSubscriptionToken scheduleTableLocationProviderRefresh(@NotNull
 @NotNull AbstractTableLocationProvider tableLocationProvider,
 long refreshIntervalMillis)

Description copied from interface: TableDataRefreshService

Schedule run for an AbstractTableLocationProvider.

Specified by:

scheduleTableLocationProviderRefresh in interface TableDataRefreshService

Parameters:

tableLocationProvider - The table location provider

refreshIntervalMillis - The interval in milliseconds between refreshes

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 using an implementation-defined default refresh interval

Specified by:

scheduleTableLocationRefresh in interface TableDataRefreshService

Parameters:

tableLocation - The table location

Returns:

A subscription token to be used for matching, which also supports cancellation

scheduleTableLocationRefresh

public TableDataRefreshService.CancellableSubscriptionToken scheduleTableLocationRefresh(@NotNull
 @NotNull AbstractTableLocation tableLocation,
 long refreshIntervalMillis)

Description copied from interface: TableDataRefreshService

Schedule run for an AbstractTableLocation.

Specified by:

scheduleTableLocationRefresh in interface TableDataRefreshService

Parameters:

tableLocation - The table location

refreshIntervalMillis - The interval in milliseconds between refreshes

Returns:

A subscription token to be used for matching, which also supports cancellation