This commit is contained in:
Athou
2015-07-27 14:38:52 +02:00
parent cba3fbeb5f
commit 9424237534
4 changed files with 11 additions and 11 deletions

View File

@@ -5,11 +5,11 @@ import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import lombok.extern.slf4j.Slf4j;
import com.codahale.metrics.Gauge;
import com.codahale.metrics.MetricRegistry;
import lombok.extern.slf4j.Slf4j;
/**
* Wraps a {@link ThreadPoolExecutor} instance. Blocks when queue is full instead of rejecting the task. Allow priority queueing by using
* {@link Task} instead of {@link Runnable}
@@ -43,7 +43,7 @@ public class FeedRefreshExecutor {
if (t != null) {
log.error("thread from pool {} threw a runtime exception", poolName, t);
}
};
}
};
pool.setRejectedExecutionHandler(new RejectedExecutionHandler() {
@Override