You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2009/07/30 21:15:06 UTC

svn commit: r799411 - /incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/spi/transport/vm/VmTransport.java

Author: cwiklik
Date: Thu Jul 30 19:15:06 2009
New Revision: 799411

URL: http://svn.apache.org/viewvc?rev=799411&view=rev
Log:
UIMA-1439 Removed wait loop to wait for threads to finish

Modified:
    incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/spi/transport/vm/VmTransport.java

Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/spi/transport/vm/VmTransport.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/spi/transport/vm/VmTransport.java?rev=799411&r1=799410&r2=799411&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/spi/transport/vm/VmTransport.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/spi/transport/vm/VmTransport.java Thu Jul 30 19:15:06 2009
@@ -39,6 +39,7 @@
 import org.apache.uima.aae.message.AsynchAEMessage;
 import org.apache.uima.aae.message.UIMAMessage;
 import org.apache.uima.aae.spi.transport.SpiListener;
+import org.apache.uima.aae.spi.transport.UimaMessage;
 import org.apache.uima.aae.spi.transport.UimaMessageDispatcher;
 import org.apache.uima.aae.spi.transport.UimaMessageListener;
 import org.apache.uima.aae.spi.transport.UimaTransport;
@@ -111,19 +112,12 @@
   public void stopIt() throws UimaSpiException {
     executor.purge();
     executor.shutdownNow();
+    workQueue.clear();
     Set <Entry<String, UimaVmMessageDispatcher>> set = dispatchers.entrySet();
     for( Entry<String, UimaVmMessageDispatcher> entry: set) {
       UimaVmMessageDispatcher dispatcher = entry.getValue();
       dispatcher.stop();
     }
-    while( !executor.isShutdown()) {
-      Thread.currentThread().getThreadGroup().list();
-      synchronized(this) {
-        try {
-          this.wait(50);
-        } catch( InterruptedException e) {break;}
-      }
-    } 
     if ( executor.isShutdown() && threadGroup.activeCount() == 0) {
       try {
         threadGroup.destroy();