Optimal ThreadPool

Utils.java

public static ThreadPoolExecutor createThreadPool(
        int corePoolSize,
        int maxPoolSize,
        final String threadNamePrefix,
        long keepAliveSeconds
) {
    ThreadPoolExecutor result = new ThreadPoolExecutor(
            corePoolSize, maxPoolSize, keepAliveSeconds, TimeUnit.SECONDS,
            new LinkedTransferQueue<Runnable>() {
                @Override
                public boolean offer(Runnable e) {
                    return tryTransfer(e);
                }
            },
            new ThreadFactory() {
                final AtomicInteger counter = new AtomicInteger();

                public Thread newThread(@NonNull Runnable runnable) {
                    return new Thread(runnable, threadNamePrefix + "-" + counter.incrementAndGet());
                }
            },
            new RejectedExecutionHandler() {
                @Override
                public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
                    try {
                        executor.getQueue().put(r);
                    } catch (InterruptedException ex) {
                        Thread.currentThread().interrupt();
                    }
                }
            });

    result.allowCoreThreadTimeOut(true);

    return result;
}