Build 1.0_r1(from source)

Class RefQueueWorker

  extended by org.apache.http.impl.conn.tsccm.RefQueueWorker
All Implemented Interfaces:

public class RefQueueWorker
extends Object
implements Runnable

A worker thread for processing queued references. References can be queued automatically by the garbage collector. If that feature is used, a daemon thread should be executing this worker. It will pick up the queued references and pass them on to a handler for appropriate processing.

Field Summary
protected  RefQueueHandler refHandler
          The handler for the references found.
protected  ReferenceQueue<?> refQueue
          The reference queue to monitor.
protected  Thread workerThread
          The thread executing this handler.
Constructor Summary
RefQueueWorker(ReferenceQueue<?> queue, RefQueueHandler handler)
          Instantiates a new worker to listen for lost connections.
Method Summary
 void run()
          The main loop of this worker.
 void shutdown()
          Shuts down this worker.
 String toString()
          Obtains a description of this worker.
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail


protected final ReferenceQueue<?> refQueue
The reference queue to monitor.


protected final RefQueueHandler refHandler
The handler for the references found.


protected volatile Thread workerThread
The thread executing this handler. This attribute is also used as a shutdown indicator.

Constructor Detail


public RefQueueWorker(ReferenceQueue<?> queue,
                      RefQueueHandler handler)
Instantiates a new worker to listen for lost connections.

queue - the queue on which to wait for references
handler - the handler to pass the references to
Method Detail


public void run()
The main loop of this worker. If initialization succeeds, this method will only return after shutdown(). Only one thread can execute the main loop at any time.

Specified by:
run in interface Runnable


public void shutdown()
Shuts down this worker. It can be re-started afterwards by another call to run().


public String toString()
Obtains a description of this worker.

toString in class Object
a descriptive string for this worker

Build 1.0_r1(from source)

Please submit a feedback, bug or feature