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 and Description
private java.util.concurrent.ExecutorService	executor

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

awaitTermination

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

Visible for testing.

Throws:

java.lang.InterruptedException