带你读《2022技术人的百宝黑皮书》——合理使用线程池以及线程变量（6）

/**
*As task queue specifically designed to run with a thread pool executor. The
*task queue is optimised to properly utilize threads within a thread pool
*executor. If you use a normal queue, the executor will spawn threads when
*there are idle threads and you wont be able to force items onto the queue
*itself.
*/
public class TaskQueue extends LinkedBlockingQueue<Runnable> {
public boolean force(Runnable o, long timeout, TimeUnit unit) throws InterruptedException {
if ( parent==null || parent.isShutdown() ) throw new RejectedExecutionException("Executor not running, can't force a command into the queue");

/**
* A Thread implementation that records the time at which it was created.
*
*/
public class TaskThread extends Thread {
private final long creationTime;
public TaskThread(ThreadGroup group, Runnable target, String name) { super(group, new WrappingRunnable(target), name); this.creationTime = System.currentTimeMillis();
}
/**
*Wraps a {@link Runnable} to swallow any {@link StopPooledThreadException}
*instead of letting it go and potentially trigger a break in a debugger.
*/
private static class WrappingRunnable implements Runnable { private Runnable wrappedRunnable; WrappingRunnable(Runnable wrappedRunnable) {
this.wrappedRunnable = wrappedRunnable;
}
@Override   public void run() {
try {
wrappedRunnable.run();
} catch(StopPooledThreadException exc) {
//expected : we just swallow the exception to avoid disturbing
//debuggers like eclipse's
log.debug("Thread exiting on purpose", exc);
}
}
}
}