How to pause/resume all threads in an ExecutorService in Java?

by

To answer my own question, I found an example of a PausableThreadPoolExecutor in the javadocs of ThreadPoolExecutor itself. Here is my version using Guava’s Monitors:

import com.google.common.util.concurrent.Monitor;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadFactory;

public class PausableExecutor extends ScheduledThreadPoolExecutor {

    private boolean isPaused;

    private final Monitor monitor = new Monitor();
    private final Monitor.Guard paused = new Monitor.Guard(monitor) {
        @Override
        public boolean isSatisfied() {
            return isPaused;
        }
    };

    private final Monitor.Guard notPaused = new Monitor.Guard(monitor) {
        @Override
        public boolean isSatisfied() {
            return !isPaused;
        }
    };

    public PausableExecutor(int corePoolSize, ThreadFactory threadFactory) {
        super(corePoolSize, threadFactory);
    }

    protected void beforeExecute(Thread t, Runnable r) {
        super.beforeExecute(t, r);
        monitor.enterWhenUninterruptibly(notPaused);
        try {
            monitor.waitForUninterruptibly(notPaused);
        } finally {
            monitor.leave();
        }
    }

    public void pause() {
        monitor.enterIf(notPaused);
        try {
            isPaused = true;
        } finally {
            monitor.leave();
        }
    }

    public void resume() {
        monitor.enterIf(paused);
        try {
            isPaused = false;
        } finally {
            monitor.leave();
        }
    }
}

More Related Contents:

  1. How to wait for all threads to finish, using ExecutorService?
  2. ExecutorService that interrupts tasks after a timeout
  3. Executors.newCachedThreadPool() versus Executors.newFixedThreadPool()
  4. What are the advantages of using an ExecutorService?
  5. Java’s Fork/Join vs ExecutorService – when to use which?
  6. Impossible to make a cached thread pool with a size limit?
  7. ThreadPoolExecutor Block When Queue Is Full?
  8. Java ExecutorService: awaitTermination of all recursively created tasks
  9. ThreadPoolExecutor Block When its Queue Is Full?
  10. ExecutorCompletionService? Why do need one if we have invokeAll?
  11. Custom thread pool in Java 8 parallel stream
  12. Is there an advantage to use a Synchronized Method instead of a Synchronized Block?
  13. When and how should I use a ThreadLocal variable?
  14. What is the difference between Thread.start() and Thread.run()?
  15. How do synchronized static methods work in Java and can I use it for loading Hibernate entities?
  16. Why use a ReentrantLock if one can use synchronized(this)?
  17. Parallel streams, collectors and thread safety
  18. How do I implement task prioritization using an ExecutorService in Java 5?
  19. Constructor synchronization in Java
  20. More efficient way for pausing loop wanted
  21. Instruction reordering & happens-before relationship [duplicate]
  22. Why should I use concurrent characteristic in parallel stream with collect?
  23. Java: ExecutorService that blocks on submission after a certain queue size [duplicate]
  24. Why doesn’t volatile in java 5+ ensure visibility from another thread?
  25. Whether to use invokeAll or submit – java Executor service
  26. Handling Exceptions for ThreadPoolExecutor
  27. Java Executors: how can I stop submitted tasks?
  28. What is the easiest way to parallelize a task in java?
  29. Controlling Task execution order with ExecutorService
  30. Are 64 bit assignments in Java atomic on a 32 bit machine?

Leave a Comment