TAO/examples/Simulator/DOVEBrowser/MTDataHandlerAdapter.java

   1 // This is an adapter class for a data handler to be used in a separate
   2 // thread.  The adapter provides a push method that places an event
   3 // set into its synchronized internal MTQueue.  It runs a separate thread
   4 // which blocks until there is an event in the queue, then dequeues the
   5 // event and then unpacks it and updates the underlying data handler.
   6
   7 public class  MTDataHandlerAdapter extends Thread
   8 {
   9   // Both the queue and the underlying data handler are private
  10   private MTQueue queue_ = null;
  11   private DataHandler dataHandler_ = null;
  12   private boolean use_queueing_ = false;
  13
  14   // Constructor.
  15   MTDataHandlerAdapter (DataHandler dh, boolean use_queueing)
  16     {
  17       dataHandler_ = dh;
  18       use_queueing_ = use_queueing;
  19       if (use_queueing_)
  20         {
  21           queue_ = new MTQueue ();
  22         }
  23     }
  24
  25   // Enqueue an event set for the handler thread.
  26   public void push (RtecEventComm.Event[] events)
  27     {
  28       //      System.out.println ("in MTDataHandlerAdapter.push");
  29
  30       if (use_queueing_)
  31         {
  32           //          System.out.println ("MTDataHandlerAdapter.push queueing events");
  33           queue_.enqueue_tail (events);
  34         }
  35       else
  36         {
  37           for (int i = 0; i < events.length; ++i)
  38             {
  39               if(events[i].header.type ==
  40                  PushConsumer.ACE_ES_EVENT_NOTIFICATION)
  41                 {
  42                   //                  System.out.println ("MTDataHandlerAdapter.push updating data handler");
  43                   dataHandler_.update (events[i]);
  44                 }
  45             }
  46         }
  47     }
  48
  49   // Process enqueued event sets in a separate thread.
  50   public void run ()
  51     {
  52       // Loop forever, handling events.
  53       for (;;)
  54         {
  55           try
  56             {
  57               // Pull an event set from the head of the queue
  58              RtecEventComm.Event[] events =
  59                 (RtecEventComm.Event[]) queue_.dequeue_head ();
  60
  61               for (int i = 0; i < events.length; ++i)
  62                 {
  63                   if(events[i].header.type ==
  64                      PushConsumer.ACE_ES_EVENT_NOTIFICATION)
  65                     {
  66                       dataHandler_.update (events[i]);
  67                     }
  68                 }
  69             }
  70           catch(org.omg.CORBA.SystemException e)
  71             {
  72               System.err.println(e);
  73             }
  74         }
  75     }
  76 }
  77
  78