Package org.apache.hc.client5.http.impl.cache

Class CacheRevalidatorBase

java.lang.Object

org.apache.hc.client5.http.impl.cache.CacheRevalidatorBase

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

DefaultAsyncCacheRevalidator, DefaultCacheRevalidator

class CacheRevalidatorBase
extends Object
implements Closeable

Abstract cache re-validation class.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	CacheRevalidatorBase.ScheduledExecutor

Field Summary

Fields

Modifier and Type	Field	Description
private final ConcurrentCountMap<String>	failureCache
private static final org.slf4j.Logger	LOG
private final Set<String>	pendingRequest
private final CacheRevalidatorBase.ScheduledExecutor	scheduledExecutor
private final SchedulingStrategy	schedulingStrategy

Constructor Summary

Constructors

Constructor	Description
CacheRevalidatorBase(ScheduledThreadPoolExecutor scheduledThreadPoolExecutor, SchedulingStrategy schedulingStrategy)	Create CacheValidator which will make ache revalidation requests using the supplied SchedulingStrategy and ScheduledThreadPoolExecutor.
CacheRevalidatorBase(CacheRevalidatorBase.ScheduledExecutor scheduledExecutor, SchedulingStrategy schedulingStrategy)	Create CacheValidator which will make ache revalidation requests using the supplied SchedulingStrategy and CacheRevalidatorBase.ScheduledExecutor.

Method Summary

Modifier and Type	Method	Description
void	awaitTermination(org.apache.hc.core5.util.Timeout timeout)
void	close()
(package private) Set<String>	getScheduledIdentifiers()
(package private) boolean	isStale(org.apache.hc.core5.http.HttpResponse httpResponse)	Determines if the given response is generated from a stale cache entry.
(package private) void	jobFailed(String identifier)
(package private) void	jobSuccessful(String identifier)
(package private) void	scheduleRevalidation(String cacheKey, Runnable command)	Schedules an asynchronous re-validation
static CacheRevalidatorBase.ScheduledExecutor	wrap(ScheduledExecutorService executorService)

Methods inherited from class java.lang.Object

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

Field Details

scheduledExecutor

private final CacheRevalidatorBase.ScheduledExecutor scheduledExecutor

schedulingStrategy

private final SchedulingStrategy schedulingStrategy

pendingRequest

private final Set<String> pendingRequest

failureCache

private final ConcurrentCountMap<String> failureCache

LOG

private static final org.slf4j.Logger LOG

Constructor Details

CacheRevalidatorBase

public CacheRevalidatorBase(CacheRevalidatorBase.ScheduledExecutor scheduledExecutor,
 SchedulingStrategy schedulingStrategy)

Create CacheValidator which will make ache revalidation requests using the supplied SchedulingStrategy and CacheRevalidatorBase.ScheduledExecutor.

CacheRevalidatorBase

public CacheRevalidatorBase(ScheduledThreadPoolExecutor scheduledThreadPoolExecutor,
 SchedulingStrategy schedulingStrategy)

Create CacheValidator which will make ache revalidation requests using the supplied SchedulingStrategy and ScheduledThreadPoolExecutor.

Method Details

wrap

public static CacheRevalidatorBase.ScheduledExecutor wrap(ScheduledExecutorService executorService)

scheduleRevalidation

void scheduleRevalidation(String cacheKey,
 Runnable command)

Schedules an asynchronous re-validation

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

awaitTermination

public void awaitTermination(org.apache.hc.core5.util.Timeout timeout)
                      throws InterruptedException

Throws:

InterruptedException

jobSuccessful

void jobSuccessful(String identifier)

jobFailed

void jobFailed(String identifier)

getScheduledIdentifiers

Set<String> getScheduledIdentifiers()

isStale

boolean isStale(org.apache.hc.core5.http.HttpResponse httpResponse)

Determines if the given response is generated from a stale cache entry.

Parameters:

httpResponse - the response to be checked

Returns:

whether the response is stale or not