com.android.volley

Class CacheDispatcher

java.lang.Object

java.lang.Thread

com.android.volley.CacheDispatcher

All Implemented Interfaces:

java.lang.Runnable

public class CacheDispatcher
extends java.lang.Thread

Provides a thread for performing cache triage on a queue of requests. Requests added to the specified cache queue are resolved from cache. Any deliverable response is posted back to the caller via a ResponseDelivery. Cache misses and responses that require refresh are enqueued on the specified network queue for processing by a NetworkDispatcher.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private static boolean	DEBUG
private Cache	mCache The cache to read from.
private java.util.concurrent.BlockingQueue<Request<?>>	mCacheQueue The queue of requests coming in for triage.
private ResponseDelivery	mDelivery For posting responses.
private java.util.concurrent.BlockingQueue<Request<?>>	mNetworkQueue The queue of requests going out to the network.
private boolean	mQuit Used for telling us to die.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
CacheDispatcher(java.util.concurrent.BlockingQueue<Request<?>> cacheQueue, java.util.concurrent.BlockingQueue<Request<?>> networkQueue, Cache cache, ResponseDelivery delivery) Creates a new cache triage dispatcher thread.

Method Summary

Modifier and Type	Method and Description
void	quit() Forces this dispatcher to quit immediately.
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

DEBUG

private static final boolean DEBUG

mCacheQueue

private final java.util.concurrent.BlockingQueue<Request<?>> mCacheQueue

The queue of requests coming in for triage.

mNetworkQueue

private final java.util.concurrent.BlockingQueue<Request<?>> mNetworkQueue

The queue of requests going out to the network.

mCache

private final Cache mCache

The cache to read from.

mDelivery

private final ResponseDelivery mDelivery

For posting responses.

mQuit

private volatile boolean mQuit

Used for telling us to die.

Constructor Detail

CacheDispatcher

public CacheDispatcher(java.util.concurrent.BlockingQueue<Request<?>> cacheQueue,
                       java.util.concurrent.BlockingQueue<Request<?>> networkQueue,
                       Cache cache,
                       ResponseDelivery delivery)

Creates a new cache triage dispatcher thread. You must call Thread.start() in order to begin processing.

Parameters:

cacheQueue - Queue of incoming requests for triage

networkQueue - Queue to post requests that require network to

cache - Cache interface to use for resolution

delivery - Delivery interface to use for posting responses

Method Detail

quit

public void quit()

Forces this dispatcher to quit immediately. If any requests are still in the queue, they are not guaranteed to be processed.

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread