WebSVN – XServices – Diff – /xservices/trunk/src/java/net/brutex/xservices/util/cache/FindingsCacheServlet.java

 import java.util.ArrayList;
 import java.util.Enumeration;
 import java.util.Iterator;
 import java.util.List;
 import java.util.concurrent.ExecutorService;
+import java.util.concurrent.TimeUnit;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import javax.servlet.ServletContext;
 import javax.servlet.ServletException;
 import javax.servlet.http.HttpServlet;
 	private static final long serialVersionUID = 4041338473949999960L;
 	private final static Logger logger = Logger
 			.getLogger(FindingsCacheServlet.class);
 	private final List<File> configfiles = new ArrayList<File>();
 	private final ObjectFactory FACTORY = new ObjectFactory();
+	private ExecutorService executor;
 	@Override
 	public void init() throws ServletException {
 		super.init();
-		ExecutorService executor = (ExecutorService) getServletContext()
+		executor = (ExecutorService) getServletContext()
 				.getAttribute("CACHE_EXECUTOR");
 			executor.submit(new ThisRunnable(cbean));
 			finding.setROOT(item.getROOT());
 			return finding;
+		}
+	}
+	/* (non-Javadoc)
+	 * @see javax.servlet.GenericServlet#destroy()
+	 */
+	@Override
+	public void destroy() {
+		// TODO Auto-generated method stub
+		executor.shutdown();
+		try {
+			executor.awaitTermination(3, TimeUnit.SECONDS);
+			logger.info("Cache Worker Threads have shut down.");
+		} catch (InterruptedException e) {
+			logger.error("Cache Worker Threads did not terminate within timeout.", e);
+		}
+		super.destroy();
+	}
+}

Subversion Repositories XServices