Updates for Builds and Versions

pom.xml

@@ -146,6 +146,7 @@
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>jcl-over-slf4j</artifactId>
+            <scope>test</scope>
         </dependency>
 
         <dependency>

src/main/java/com/guicedee/guicedinjection/JobService.java

@@ -35,8 +35,13 @@ public class JobService
 	private static TimeUnit defaultWaitUnit = TimeUnit.SECONDS;
 
 	private static final JobService INSTANCE = new JobService();
+	private static ExecutorService jobCleanup = null;
 
 	public static JobService getInstance(){
+		if (jobCleanup == null)
+		{
+			jobCleanup = INSTANCE.jobCleanup();
+		}
 		return INSTANCE;
 	}
 
@@ -223,6 +228,29 @@ public void waitForJob(String jobName, long timeout, TimeUnit unit)
 		service.close();
 	}
 
+	private ExecutorService jobCleanup()
+	{
+		ScheduledExecutorService jobsShutdownNotClosed = addPollingJob("JobsShutdownNotClosed", () -> {
+			for (String jobPool : getInstance().getJobPools())
+			{
+				ExecutorService executorService = serviceMap.get(jobPool);
+				if(executorService.isShutdown() && !executorService.isTerminated())
+				{
+					log.fine("Closing unfinished job - " + jobPool);
+					removeJob(jobPool);
+				}
+				if(executorService.isShutdown() && executorService.isTerminated())
+				{
+					log.fine("Cleaning terminated job - " + jobPool);
+					executorService.close();
+					serviceMap.remove(jobPool);
+				}
+			}
+		}, 2, TimeUnit.MINUTES);
+
+		return jobsShutdownNotClosed;
+	}
+
 	/**
 	 * Adds a static run once job to the monitored collections
 	 *