线程解决并发问题

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();
}
}
}
}

即可。