for (List<PlaceInfoBean> currentList : averageAssignList) {
tp.execute(()->{
});
}
tp.shutdown();
while (true) {
if (tp.isTerminated()) {
logger.info("已经执行完成的线程数:" + tp.getCompletedTaskCount());
logger.info("正在执行的线程数:" + tp.getActiveCount());
long endTime = System.currentTimeMillis();
long totalTime = endTime - queryzhStart;
double threadTime = Double.parseDouble(Long.toString(totalTime));
logger.info("查询impala接口定时任务结束,线程执行总耗时:" + threadTime / (double) 1000 + "秒");
break;
}
logger.info("正在执行“);
Thread.sleep(200);
}
上面是主线程的代码,创建了一个能同时执行2个线程的线程池,并投入5个线程,当5个线程都执行完毕后打印---“结束了!”字符串。exe.shutdown();该方法在加入线程队列的线程执行完之前不会执行。exe.isTerminated();当shutdown()或者shutdownNow()执行了之后才会执行,并返回true。在上面的代码中必须有exe.isTerminated()的判断,否则在投入5个线程到线程池后会直接打印:“结束了”。不能达到我们想要的效果。通过while(true)循环判断exe.isTerminated()重生之大文豪的值,为了防止过多的判断浪费资源,可设置线程睡眠Thread.sleep(200);正是由于这个睡眠,所以当所有线程池中的线程都执行完后,有可能延迟200ms才执行"结束了"语句。这个参数越小延迟越小,结果越准确。