为了回答我自己的问题，我
PausableThreadPoolExecutor在
ThreadPoolExecutor
本身的javadocs中找到了一个示例。这是我使用番石榴显示器的版本：
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(); } }}
