boundedexecutor

gistfile1.java

public class BoundedExecutorService {
	BlockingQueue<Runnable> blockingQueue = new ArrayBlockingQueue<Runnable>(4);
	RejectedExecutionHandler rejectedExecutionHandler = new ThreadPoolExecutor.CallerRunsPolicy();
	private ExecutorService executorService = new ThreadPoolExecutor(2, 2, 0L, TimeUnit.MILLISECONDS,
			blockingQueue, rejectedExecutionHandler);

	public void execute(Runnable command) {
		executorService.submit(command);
	}

	public void shutdown() {
		try {
			executorService.awaitTermination(60, TimeUnit.MINUTES);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}

nice