Changeset 982 for AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/concurrent/MultiThreadedTaskRunner.java

Timestamp:

08/28/10 21:55:08 (21 months ago)

Author:

kasper

Message:

Ticket #382: Added CLI for executing jobs

File:

• AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/concurrent/MultiThreadedTaskRunner.java (modified) (1 diff)

AnalyzerBeans/trunk/src/main/java/org/eobjects/analyzer/job/concurrent/MultiThreadedTaskRunner.java

@@ -8 +8 @@
 import org.slf4j.LoggerFactory;
 
-public class MultiThreadedTaskRunner implements TaskRunner {
+public final class MultiThreadedTaskRunner implements TaskRunner {
 
         private final Logger logger = LoggerFactory.getLogger(getClass());
-        
-        private ExecutorService threadPool;
+
+        private ExecutorService executorService;
 
         public MultiThreadedTaskRunner() {
-                threadPool = Executors.newCachedThreadPool();
+                executorService = Executors.newCachedThreadPool();
         }
-        
+
         public MultiThreadedTaskRunner(int numThreads) {
-                threadPool = Executors.newFixedThreadPool(numThreads);
+                executorService = Executors.newFixedThreadPool(numThreads);
+        }
+
+        @Override
+        public void run(Task task) {
+                logger.debug("run({})", task);
+                executorService.submit(new TaskRunnable(task));
+        }
+
+        @Override
+        public void shutdown() {
+                logger.info("shutdown() called, shutting down executor service");
+                executorService.shutdown();
         }
         
         @Override
-        public void run(Task task) {
-                logger.debug("run({})", task);
-                threadPool.submit(new TaskRunnable(task));
+        protected void finalize() throws Throwable {
+                shutdown();
         }
 }