Package org.apache.http.impl.client.cache

Class ImmediateSchedulingStrategy

java.lang.Object

org.apache.http.impl.client.cache.ImmediateSchedulingStrategy

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, SchedulingStrategy

@Contract(threading=SAFE)
public class ImmediateSchedulingStrategy
extends java.lang.Object
implements SchedulingStrategy

Immediately schedules any incoming validation request. Relies on CacheConfig to configure the used ThreadPoolExecutor.

Since:

4.3

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.concurrent.ExecutorService	executor

Constructor Summary

Constructors

Constructor	Description
ImmediateSchedulingStrategy(java.util.concurrent.ExecutorService executor)
ImmediateSchedulingStrategy(CacheConfig cacheConfig)	Uses a ThreadPoolExecutor which is configured according to the given CacheConfig.

Method Summary

Modifier and Type	Method	Description
(package private) void	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)	Visible for testing.
void	close()
void	schedule(AsynchronousValidationRequest revalidationRequest)	Schedule an AsynchronousValidationRequest to be executed.

Methods inherited from class java.lang.Object

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

Field Detail

executor

private final java.util.concurrent.ExecutorService executor

Constructor Detail

ImmediateSchedulingStrategy

public ImmediateSchedulingStrategy(CacheConfig cacheConfig)

Uses a ThreadPoolExecutor which is configured according to the given CacheConfig.

Parameters:

cacheConfig - specifies thread pool settings. See CacheConfig.getAsynchronousWorkersMax(), CacheConfig.getAsynchronousWorkersCore(), CacheConfig.getAsynchronousWorkerIdleLifetimeSecs(), and CacheConfig.getRevalidationQueueSize().

ImmediateSchedulingStrategy

ImmediateSchedulingStrategy(java.util.concurrent.ExecutorService executor)

Method Detail

schedule

public void schedule(AsynchronousValidationRequest revalidationRequest)

Description copied from interface: SchedulingStrategy

Schedule an AsynchronousValidationRequest to be executed.

Specified by:

schedule in interface SchedulingStrategy

Parameters:

revalidationRequest - the request to be executed; not null

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

awaitTermination

void awaitTermination(long timeout,
                      java.util.concurrent.TimeUnit unit)
               throws java.lang.InterruptedException

Visible for testing.

Throws:

java.lang.InterruptedException