* @param loggerIdentity
* the class to use as logger name for logging uncaught exceptions from the threads.
*/
- @SuppressWarnings("checkstyle:LoggerFactoryClassParameter") // due to loggerIdentity argument usage
+ // due to loggerIdentity argument usage
+ @SuppressWarnings("checkstyle:LoggerFactoryClassParameter")
public CachedThreadPoolExecutor(final int maximumPoolSize, final int maximumQueueSize, final String threadPrefix,
- Class<?> loggerIdentity) {
+ final Class<?> loggerIdentity) {
// We're using a custom SynchronousQueue that has a backing bounded LinkedBlockingQueue.
// We don't specify any core threads (first parameter) so, when a task is submitted,
// the base class will always try to offer to the queue. If there is an existing waiting
private static final long POLL_WAIT_TIME_IN_MS = 300;
- @SuppressFBWarnings("SE_BAD_FIELD") // Runnable is not Serializable
+ @SuppressFBWarnings("SE_BAD_FIELD")
+ // Runnable is not Serializable
private final TrackingLinkedBlockingQueue<Runnable> backingQueue;
ExecutorQueue(final int maxBackingQueueSize) {
* the class to use as logger name for logging uncaught exceptions from the threads.
*/
public FastThreadPoolExecutor(final int maximumPoolSize, final int maximumQueueSize, final String threadPrefix,
- Class<?> loggerIdentity) {
+ final Class<?> loggerIdentity) {
this(maximumPoolSize, maximumQueueSize, DEFAULT_IDLE_TIMEOUT_IN_SEC, TimeUnit.SECONDS,
threadPrefix, loggerIdentity);
}
* @param loggerIdentity
* the class to use as logger name for logging uncaught exceptions from the threads.
*/
- @SuppressWarnings("checkstyle:LoggerFactoryClassParameter") // due to loggerIdentity argument usage
+ // due to loggerIdentity argument usage
+ @SuppressWarnings("checkstyle:LoggerFactoryClassParameter")
public FastThreadPoolExecutor(final int maximumPoolSize, final int maximumQueueSize, final long keepAliveTime,
- final TimeUnit unit, final String threadPrefix, Class<?> loggerIdentity) {
+ final TimeUnit unit, final String threadPrefix, final Class<?> loggerIdentity) {
// We use all core threads (the first 2 parameters below equal) so, when a task is submitted,
// if the thread limit hasn't been reached, a new thread will be spawned to execute
// the task even if there is an existing idle thread in the pool. This is faster than