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();