ThreadsMu.java

package mu;

import com.google.common.util.concurrent.ThreadFactoryBuilder;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadsMu {

 public static void sleep (long duration, TimeUnit timeUnit) {
 try {
 Thread.sleep(timeUnit.toMillis(duration));
 } catch (InterruptedException e) {
 throw ExceptionsMu.handleInterruptedException(e);
 }
 }

 public static ThreadPoolExecutor createThreadPoolExecutor(int threadPoolSize, int workQueueSize, String poolName) {
 BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(workQueueSize);
 ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
 threadPoolSize,
 threadPoolSize,
 1,
 TimeUnit.MINUTES,
 workQueue,
 new ThreadFactoryBuilder().setNameFormat(poolName + "-%d").build());
 threadPoolExecutor.allowCoreThreadTimeOut(true);
 return threadPoolExecutor;
 }
}