src/org/lwes/listener/ThreadedEnqueuer.java

   1 package org.lwes.listener;
   2
   3 import java.io.IOException;
   4 import java.util.List;
   5
   6 public abstract class ThreadedEnqueuer implements Runnable {
   7         protected List<QueueElement> queue = null;
   8
   9         /**
  10          * Default constructor.
  11          */
  12         public ThreadedEnqueuer() {
  13         }
  14
  15         /**
  16          * Returns the queue to use for this enqueuer
  17          * @return the List queue
  18          */
  19         public synchronized List<QueueElement> getQueue() {
  20                 return this.queue;
  21         }
  22
  23         /**
  24          * Sets the queue to use for this enqueuer.
  25          * Warning: this List must be thread-synchronized!
  26          * @param queue the thread-synchronized List element
  27          */
  28         public synchronized void setQueue(List<QueueElement> queue) {
  29                 this.queue = queue;
  30         }
  31
  32         /**
  33          * Default initialize() method.  Should be overridden by classes extending ThreadedEnqueuer.
  34          */
  35         public void initialize() throws IOException {
  36         }
  37
  38         /**
  39          * Default shutdown() method.  Should be overridden by classes extending ThreadedDequeuer.
  40          */
  41         public void shutdown() {
  42         }
  43
  44         /**
  45          * Default run() method.  Should be overridden by classes extending ThreadedDequeuer.
  46          */
  47         public void run() {
  48         }
  49 }