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

Class CacheRevalidatorBase

java.lang.Object

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

DefaultAsyncCacheRevalidator, DefaultCacheRevalidator

class CacheRevalidatorBase
extends java.lang.Object
implements java.io.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 ConcurrentCountMap<java.lang.String>	failureCache
private java.util.concurrent.locks.ReentrantLock	lock
private static org.slf4j.Logger	LOG
private java.util.Set<java.lang.String>	pendingRequest
private CacheRevalidatorBase.ScheduledExecutor	scheduledExecutor
private SchedulingStrategy	schedulingStrategy

Constructor Summary

Constructors

Constructor	Description
CacheRevalidatorBase(java.util.concurrent.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) java.util.Set<java.lang.String>	getScheduledIdentifiers()
(package private) void	jobFailed(java.lang.String identifier)
(package private) void	jobSuccessful(java.lang.String identifier)
(package private) void	scheduleRevalidation(java.lang.String cacheKey, java.lang.Runnable command)	Schedules an asynchronous re-validation
static CacheRevalidatorBase.ScheduledExecutor	wrap(java.util.concurrent.ScheduledExecutorService executorService)

Methods inherited from class java.lang.Object

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

Field Detail

lock

private final java.util.concurrent.locks.ReentrantLock lock

scheduledExecutor

private final CacheRevalidatorBase.ScheduledExecutor scheduledExecutor

schedulingStrategy

private final SchedulingStrategy schedulingStrategy

pendingRequest

private final java.util.Set<java.lang.String> pendingRequest

failureCache

private final ConcurrentCountMap<java.lang.String> failureCache

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

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(java.util.concurrent.ScheduledThreadPoolExecutor scheduledThreadPoolExecutor,
                            SchedulingStrategy schedulingStrategy)

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

Method Detail

wrap

public static CacheRevalidatorBase.ScheduledExecutor wrap(java.util.concurrent.ScheduledExecutorService executorService)

scheduleRevalidation

void scheduleRevalidation(java.lang.String cacheKey,
                          java.lang.Runnable command)

Schedules an asynchronous re-validation

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Throws:

java.io.IOException

awaitTermination

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

Throws:

java.lang.InterruptedException

jobSuccessful

void jobSuccessful(java.lang.String identifier)

jobFailed

void jobFailed(java.lang.String identifier)

getScheduledIdentifiers

java.util.Set<java.lang.String> getScheduledIdentifiers()