Using executor services

executorService.java

public class LimitedQueue<E> extends LinkedBlockingQueue<E> 
{
    public LimitedQueue(int maxSize)
    {
        super(maxSize);
    }

    @Override
    public boolean offer(E e)
    {
        // turn offer() and add() into a blocking calls (unless interrupted)
        try {
            put(e);
            return true;
        } catch(InterruptedException ie) {
            Thread.currentThread().interrupt();
        }
        return false;
    }

}
ThreadPoolExecutor executor = new ThreadPoolExecutor(numWorkerThreads, numWorkerThreads,
							  0L, TimeUnit.MILLISECONDS,
							  new LimitedQueue<Runnable>(maxQueue));
							  
executor.submit(new Runnable() {....});
executor.shutdown();

try {
	executor.awaitTermination(50, TimeUnit.MINUTES);
} catch (InterruptedException e) {
	e.printStackTrace();
}