Class NonBlocking

java.lang.Object

software.amazon.awssdk.utils.cache.NonBlocking

All Implemented Interfaces:

AutoCloseable, CachedSupplier.PrefetchStrategy, SdkAutoCloseable

@SdkProtectedApi
public class NonBlocking
extends Object
implements CachedSupplier.PrefetchStrategy

A CachedSupplier.PrefetchStrategy that will run a single thread in the background to update the value. A call to prefetch on this strategy will never return. Multiple calls to prefetch(Runnable) will still only result in one background task performing the update.

Constructor Summary

Constructors

Constructor	Description
NonBlocking(String asyncThreadName)	Create a non-blocking prefetch strategy that uses the provided value for the name of the background thread that will be performing the update.

Method Summary

Modifier and Type	Method	Description
void	close()	Free any resources associated with the strategy.
<T> RefreshResult<T>	fetch(Supplier<RefreshResult<T>> supplier)	Invoke the provided supplier to retrieve the refresh result.
void	initializeCachedSupplier(CachedSupplier<?> cachedSupplier)	Invoked when the prefetch strategy is registered with a CachedSupplier.
boolean	isTaskScheduled()
void	prefetch(Runnable valueUpdater)	Execute the provided value updater to update the cache.
void	runWithInstanceThreadName(Runnable runnable)
void	tryRunBackgroundTask(Runnable runnable)
void	tryRunBackgroundTask(Runnable runnable, Runnable runOnCompletion)
void	updateTask(ScheduledFuture<?> newTask)

Methods inherited from class java.lang.Object

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

Constructor Details

NonBlocking

public NonBlocking(String asyncThreadName)

Create a non-blocking prefetch strategy that uses the provided value for the name of the background thread that will be performing the update.

Method Details

isTaskScheduled

@SdkTestInternalApi
public boolean isTaskScheduled()

initializeCachedSupplier

public void initializeCachedSupplier(CachedSupplier<?> cachedSupplier)

Description copied from interface: CachedSupplier.PrefetchStrategy

Invoked when the prefetch strategy is registered with a CachedSupplier.

Specified by:

initializeCachedSupplier in interface CachedSupplier.PrefetchStrategy

prefetch

public void prefetch(Runnable valueUpdater)

Description copied from interface: CachedSupplier.PrefetchStrategy

Execute the provided value updater to update the cache. The specific implementation defines how this is invoked.

Specified by:

prefetch in interface CachedSupplier.PrefetchStrategy

fetch

public <T> RefreshResult<T> fetch(Supplier<RefreshResult<T>> supplier)

Description copied from interface: CachedSupplier.PrefetchStrategy

Invoke the provided supplier to retrieve the refresh result. This is useful for prefetch strategies to override when they care about the refresh result.

Specified by:

fetch in interface CachedSupplier.PrefetchStrategy

close

public void close()

Description copied from interface: CachedSupplier.PrefetchStrategy

Free any resources associated with the strategy. This is invoked when the CachedSupplier.close() method is invoked.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CachedSupplier.PrefetchStrategy

Specified by:

close in interface SdkAutoCloseable

updateTask

public void updateTask(ScheduledFuture<?> newTask)

tryRunBackgroundTask

public void tryRunBackgroundTask(Runnable runnable)

tryRunBackgroundTask

public void tryRunBackgroundTask(Runnable runnable,
 Runnable runOnCompletion)

runWithInstanceThreadName

public void runWithInstanceThreadName(Runnable runnable)