java 多线程 执行完成 退出 关闭

本来多线程就不熟悉，每次做到这里 总会遇到这个问题，解决一次 忘一次， 这记下来

?

?

? private static int THREAD_NUM = 10; ?线程总数

? private AtomicInteger threadNum = new AtomicInteger(0); ? 每个线程执行完 了 记录一个标记

es.shutdown(); 这个只能让线程池退出，并不能让 主线程推出，所以这里要给一个 ?next ?标记，当线程池 关闭之后，告诉主线程， ?这是主线程 ?继续向下执行；

?

ExecutorService es = Executors.newFixedThreadPool(THREAD_NUM);

? ? for (int i = 0; i < THREAD_NUM; i++) {

? ? ? es.execute(new InitLangFangData(loopStr));

? ? }

? ? boolean next = true;// 主线程退出标记

? ? while (next) {

? ? ? if (THREAD_NUM == threadNum.get()) {

? ? ? ? es.shutdown(); ? //这里是让 ?线程池推出使用的 ，但是主线程并没有退出

? ? ? ? if (es.isShutdown()) {

? ? ? ? ? next = false;

? ? ? ? }

? ? ? } else {

? ? ? ? Thread.sleep(5000);

? ? ? }

? ? }

?

?

class InitLangFangData extends Thread

? {

? ? private String loopStr;

?

? ? public InitLangFangData(String loopStr)

? ? {

?

? ? ? this.loopStr = loopStr;

? ? }

?

? ? public void run()

? ? {

? ? ? try {

? ? ? ? initData(loopStr);

? ? ? } catch (DataCellException e) {

? ? ? ? logger.error(e.getMessage(), e);

? ? ? } catch (IOException e) {

? ? ? ? logger.error(e.getMessage(), e);

? ? ? }

? ? ? threadNum.getAndIncrement();

? ? }

? }