Java: ExecutorService that blocks on submission after a certain queue size [duplicate]

by

I have done this same thing. The trick is to create a BlockingQueue where the offer() method is really a put(). (you can use whatever base BlockingQueue impl you want).

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;
    }

}

Note that this only works for thread pool where corePoolSize==maxPoolSize so be careful there (see comments).

More Related Contents:

  1. How to wait for all threads to finish, using ExecutorService?
  2. ExecutorService, how to wait for all tasks to finish
  3. ExecutorService that interrupts tasks after a timeout
  4. Executors.newCachedThreadPool() versus Executors.newFixedThreadPool()
  5. Naming threads and thread-pools of ExecutorService
  6. What are the advantages of using an ExecutorService?
  7. Java’s Fork/Join vs ExecutorService – when to use which?
  8. Turning an ExecutorService to daemon in Java
  9. Impossible to make a cached thread pool with a size limit?
  10. ThreadPoolExecutor Block When Queue Is Full?
  11. Java ExecutorService: awaitTermination of all recursively created tasks
  12. FixedThreadPool vs CachedThreadPool: the lesser of two evils
  13. ThreadPoolExecutor Block When its Queue Is Full?
  14. How Threadpool re-use Threads and how it works
  15. How to pause/resume all threads in an ExecutorService in Java?
  16. Whether to use invokeAll or submit – java Executor service
  17. Future task of ExecutorService not truly cancelling
  18. Controlling Task execution order with ExecutorService
  19. Removing all queued tasks of an ThreadPoolExecutor
  20. What is optimum thread pool size for simple program running cpu based tasks in Java
  21. Dynamic Thread Pool
  22. ExecutorCompletionService? Why do need one if we have invokeAll?
  23. Volatile boolean vs AtomicBoolean
  24. How to properly use Java Executor?
  25. How to use ConcurrentLinkedQueue?
  26. Simplest and understandable example of volatile keyword in Java
  27. Allowing the this reference to escape
  28. Why does java.util.concurrent.ArrayBlockingQueue use ‘while’ loops instead of ‘if’ around calls to await()?
  29. How can I wrap a method so that I can kill its execution if it exceeds a specified timeout?
  30. How to interrupt underlying execution of CompletableFuture

Leave a Comment