public final class MyThreadPool { /** * 线程池大小设置，系统设计等待时间最长为3000ms，单次查询数据库大约消耗600ms * <P> * 故而FACTOR设置为6 FACTOR = (1+WT/ST); */ private static final int FACTOR = 6; /** * 线程池大小设置,N为CPU核心数 * <P> * N = N * FACTOR */ private static final ExecutorService executorService = Executors .newFixedThreadPool(Runtime.getRuntime().availableProcessors() * FACTOR); private MyThreadPool() { } /** * 执行线程 * * @param command */ public static void execute(Runnable command) { executorService.execute(command); } @SuppressWarnings("rawtypes") public static Future submit(Runnable task) { return executorService.submit(task); }}
在定义一个类继承Thread，实现run方法，在该方法中写相关逻辑；
new一个该自定义的类，名称自定义,放在submit中，如下。
Future future = MyThreadPool.submit(qdt);
然后
/** * 等待各个线程任务完成 * @param futures */
private void waitForThreads(List<Future> futures) { if (futures != null) { for (Future future : futures) { try { future.get(); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } } } }
即可。
转载于:https://www.cnblogs.com/yanduanduan/p/4990783.html
