smarter way of stopping things

src/main/java/com/commafeed/backend/StartupBean.java

@@ -13,6 +13,7 @@ import javax.ejb.Singleton;
 import javax.ejb.Startup;
 import javax.inject.Inject;
 
+import org.apache.commons.lang.mutable.MutableBoolean;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -60,6 +61,8 @@ public class StartupBean {
 
 	private long startupTime;
 
+	private MutableBoolean running = new MutableBoolean(true);
+
 	@PostConstruct
 	private void init() {
 		startupTime = Calendar.getInstance().getTimeInMillis();
@@ -71,7 +74,7 @@ public class StartupBean {
 		log.info("Starting {} background threads",
 				settings.getBackgroundThreads());
 		for (int i = 0; i < settings.getBackgroundThreads(); i++) {
-			Future<Void> thread = worker.start("Thread " + i);
+			Future<Void> thread = worker.start(running, "Thread " + i);
 			threads.add(thread);
 		}
 
@@ -89,10 +92,8 @@ public class StartupBean {
 	}
 
 	@PreDestroy
-	private void shutdown() {
-		for (Future<Void> future : threads) {
-			future.cancel(true);
-		}
+	public void shutdown() {
+		running.setValue(false);
 	}
 
 }

src/main/java/com/commafeed/backend/feeds/FeedRefreshTaskGiver.java

@@ -4,11 +4,13 @@ import java.util.Calendar;
 import java.util.List;
 import java.util.Queue;
 
+import javax.annotation.PreDestroy;
 import javax.ejb.Lock;
 import javax.ejb.LockType;
 import javax.ejb.Singleton;
 import javax.inject.Inject;
 
+import com.commafeed.backend.StartupBean;
 import com.commafeed.backend.dao.FeedDAO;
 import com.commafeed.backend.model.Feed;
 import com.commafeed.backend.services.ApplicationSettingsService;
@@ -23,6 +25,9 @@ public class FeedRefreshTaskGiver {
 	@Inject
 	ApplicationSettingsService applicationSettingsService;
 
+	@Inject
+	StartupBean startupBean;
+
 	private Queue<Feed> queue = Lists.newLinkedList();
 
 	@Lock(LockType.WRITE)
@@ -39,4 +44,9 @@ public class FeedRefreshTaskGiver {
 		}
 		return queue.poll();
 	}
+
+	@PreDestroy
+	public void shutdown() {
+		startupBean.shutdown();
+	}
 }

src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java

@@ -18,6 +18,7 @@ import javax.transaction.RollbackException;
 import javax.transaction.SystemException;
 import javax.transaction.UserTransaction;
 
+import org.apache.commons.lang.mutable.MutableBoolean;
 import org.apache.commons.lang.time.DateUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -48,12 +49,10 @@ public class FeedRefreshWorker {
 	@Resource
 	private UserTransaction transaction;
 
-	private boolean running = true;
-
 	@Asynchronous
-	public Future<Void> start(String threadName) {
+	public Future<Void> start(MutableBoolean running, String threadName) {
 		log.info("{} starting", threadName);
-		while (running) {
+		while (running.isTrue()) {
 			try {
 				Feed feed = getNextFeed();
 				if (feed != null) {
@@ -69,16 +68,16 @@ public class FeedRefreshWorker {
 		}
 		return new AsyncResult<Void>(null);
 	}
-	
+
 	@Asynchronous
-	public void updateAsync(Feed feed){
+	public void updateAsync(Feed feed) {
 		try {
 			update(feed);
 		} catch (Exception e) {
 			log.error(e.getMessage(), e);
 		}
 	}
-	
+
 	private void update(Feed feed) throws NotSupportedException,
 			SystemException, SecurityException, IllegalStateException,
 			RollbackException, HeuristicMixedException,