java/test/Ice/dispatcher/Dispatcher.java

   1 // **********************************************************************
   2 //
   3 // Copyright (c) 2003-2011 ZeroC, Inc. All rights reserved.
   4 //
   5 // This copy of Ice is licensed to you under the terms described in the
   6 // ICE_LICENSE file included in this distribution.
   7 //
   8 // **********************************************************************
   9
  10 package test.Ice.dispatcher;
  11
  12 public class Dispatcher implements Runnable, Ice.Dispatcher
  13 {
  14     private static void
  15     test(boolean b)
  16     {
  17         if(!b)
  18         {
  19             throw new RuntimeException();
  20         }
  21     }
  22
  23     public Dispatcher()
  24     {
  25         _thread = new Thread(this);
  26         _thread.start();
  27     }
  28
  29     public void
  30     run()
  31     {
  32         while(true)
  33         {
  34             Runnable call = null;
  35             synchronized(this)
  36             {
  37                 if(!_terminated && _calls.isEmpty())
  38                 {
  39                     try
  40                     {
  41                         wait();
  42                     }
  43                     catch(java.lang.InterruptedException ex)
  44                     {
  45                     }
  46                 }
  47
  48                 if(!_calls.isEmpty())
  49                 {
  50                     call = _calls.poll();
  51                 }
  52                 else if(_terminated)
  53                 {
  54                     // Terminate only once all calls are dispatched.
  55                     return;
  56                 }
  57             }
  58
  59             if(call != null)
  60             {
  61                 try
  62                 {
  63                     call.run();
  64                 }
  65                 catch(Exception ex)
  66                 {
  67                     // Exceptions should never propagate here.
  68                     test(false);
  69                 }
  70             }
  71         }
  72     }
  73
  74     synchronized public void
  75     dispatch(Runnable call, Ice.Connection con)
  76     {
  77         boolean added = _calls.offer(call);
  78         assert(added);
  79         if(_calls.size() == 1)
  80         {
  81             notify();
  82         }
  83     }
  84
  85     public void
  86     terminate()
  87     {
  88         synchronized(this)
  89         {
  90             _terminated = true;
  91             notify();
  92         }
  93         while(true)
  94         {
  95             try
  96             {
  97                 _thread.join();
  98                 break;
  99             }
 100             catch(java.lang.InterruptedException ex)
 101             {
 102             }
 103         }
 104     }
 105
 106     public boolean
 107     isDispatcherThread()
 108     {
 109         return Thread.currentThread() == _thread;
 110     }
 111
 112     private java.util.Queue<Runnable> _calls = new java.util.LinkedList<Runnable>();
 113     private Thread _thread;
 114     private boolean _terminated = false;
 115 }