[MMBASE CVS] src/org/mmbase/util ThreadPools.java

[Michiel Meeuwissen]

Update of /var/cvs/src/org/mmbase/util
In directory james.mmbase.org:/tmp/cvs-serv23705

Modified Files:
        ThreadPools.java 
Log Message:
more aggresive shutting down


See also: http://cvs.mmbase.org/viewcvs/src/org/mmbase/util


Index: ThreadPools.java
===================================================================
RCS file: /var/cvs/src/org/mmbase/util/ThreadPools.java,v
retrieving revision 1.14
retrieving revision 1.15
diff -u -b -r1.14 -r1.15
--- ThreadPools.java    30 Jul 2008 10:58:08 -0000      1.14
+++ ThreadPools.java    1 Aug 2008 20:17:18 -0000       1.15
@@ -17,7 +17,7 @@
  *
  * @since MMBase 1.8
  * @author Michiel Meewissen
- * @version $Id: ThreadPools.java,v 1.14 2008/07/30 10:58:08 michiel Exp $
+ * @version $Id: ThreadPools.java,v 1.15 2008/08/01 20:17:18 michiel Exp $
  */
 public abstract class ThreadPools {
     private static final Logger log = 
Logging.getLoggerInstance(ThreadPools.class);
@@ -96,9 +96,26 @@
      * @since MMBase-1.8.4
      */
     public static void shutdown() {
-        scheduler.shutdown();
-        filterExecutor.shutdown();
-        jobsExecutor.shutdown();
+        {
+            List<Runnable> run = scheduler.shutdownNow();
+            if (run.size() > 0) {
+                log.info("Interrupted " + run);
+            }
+        }
+        {
+
+            List<Runnable> run = filterExecutor.shutdownNow();
+            if (run.size() > 0) {
+                log.info("Interrupted " + run);
+            }
+            
+        }
+        {
+            List<Runnable> run = jobsExecutor.shutdownNow();
+            if (run.size() > 0) {
+                log.info("Interrupted " + run);
+            }
+        }
     }
 
 }
_______________________________________________
Cvs mailing list
Cvs@lists.mmbase.org
http://lists.mmbase.org/mailman/listinfo/cvs