*/
private static class FlexibleRejectionHandler implements RejectedExecutionHandler {
@Override
+ @SuppressWarnings("checkstyle:parameterName")
public void rejectedExecution(final Runnable r, final ThreadPoolExecutor executor) {
try {
executor.getQueue().put(r);
extends com.google.common.util.concurrent.ForwardingBlockingQueue<Runnable> {
private final BlockingQueue<Runnable> delegate;
- public ForwardingBlockingQueue(final BlockingQueue<Runnable> delegate) {
+ ForwardingBlockingQueue(final BlockingQueue<Runnable> delegate) {
this.delegate = delegate;
}
}
@Override
- public boolean offer(final Runnable r) {
+ @SuppressWarnings("checkstyle:parameterName")
+ public boolean offer(final Runnable o) {
// ThreadPoolExecutor will spawn a new thread after core size is reached only
// if the queue.offer returns false.
return false;