@@ -0,0 +1,567 @@
+package org.finikes.sider.utils;%0A%0Aimport java.util.concurrent.ExecutorService;%0Aimport java.util.concurrent.Executors;%0A%0Apublic class ProcessWorkerThreadPool %7B%0A%09private static final int DEFAULT_THREAD_NUMBER = Runtime.getRuntime().availableProcessors() * 2;%0A%09private static ExecutorService EXEC = Executors.newFixedThreadPool(DEFAULT_THREAD_NUMBER);%0A%0A%09public static ExecutorService getExec() %7B%0A%09%09return EXEC;%0A%09%7D%0A%0A%09public static void work(Runnable runnable) %7B%0A%09%09EXEC.execute(runnable);%0A%09%7D%0A%0A%09public static void shutdown()%7B%0A%09%09ProcessWorkerThreadPool.EXEC.shutdown();%0A%09%7D%0A%7D%0A

Create ProcessWorkerThreadPool.java