com.android.volley

Class NetworkDispatcher

java.lang.Object

java.lang.Thread

com.android.volley.NetworkDispatcher

All Implemented Interfaces:

java.lang.Runnable

public class NetworkDispatcher
extends java.lang.Thread

Provides a thread for performing network dispatch from a queue of requests. Requests added to the specified queue are processed from the network via a specified Network interface. Responses are committed to cache, if eligible, using a specified Cache interface. Valid responses and errors are posted back to the caller via a ResponseDelivery.

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 Cache	mCache The cache to write to.
private ResponseDelivery	mDelivery For posting responses and errors.
private Network	mNetwork The network interface for processing requests.
private java.util.concurrent.BlockingQueue<Request<?>>	mQueue The queue of requests to service.
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
NetworkDispatcher(java.util.concurrent.BlockingQueue<Request<?>> queue, Network network, Cache cache, ResponseDelivery delivery) Creates a new network dispatcher thread.

Method Summary

Modifier and Type	Method and Description
private void	addTrafficStatsTag(Request<?> request)
private void	parseAndDeliverNetworkError(Request<?> request, VolleyError error)
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

mQueue

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

The queue of requests to service.

mNetwork

private final Network mNetwork

The network interface for processing requests.

mCache

private final Cache mCache

The cache to write to.

mDelivery

private final ResponseDelivery mDelivery

For posting responses and errors.

mQuit

private volatile boolean mQuit

Used for telling us to die.

Constructor Detail

NetworkDispatcher

public NetworkDispatcher(java.util.concurrent.BlockingQueue<Request<?>> queue,
                         Network network,
                         Cache cache,
                         ResponseDelivery delivery)

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

Parameters:

queue - Queue of incoming requests for triage

network - Network interface to use for performing requests

cache - Cache interface to use for writing responses to cache

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.

addTrafficStatsTag

private void addTrafficStatsTag(Request<?> request)

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

parseAndDeliverNetworkError

private void parseAndDeliverNetworkError(Request<?> request,
                                         VolleyError error)