A ThreadPoolExecutor that shuts down when it runs out of tasks.

RecursiveThreadPoolExecutor.java

public class RecursiveThreadPoolExecutor extends ThreadPoolExecutor {
	private AtomicInteger count;
		
	public RecursiveThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
		super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
			
		count = new AtomicInteger(0);
	}
		
	public void execute(Runnable command) {
		count.getAndIncrement();
		
		super.execute(command);
	}
		
	protected void afterExecute(Runnable r, Throwable t) {
		if(count.decrementAndGet()==0) {
			this.shutdown();
		}
	}
}