public class ConcurrentTest {
    /**
     * 多線程測(cè)試用例
     * @param threadCount 開啟線程數(shù)
     * @param run 線程執(zhí)行方法
     * @param finish 線程全部執(zhí)行結(jié)束后運(yùn)行方法
     */
    public void begin(int threadCount,Run run,Finish finish){
        CountDownLatch countDownLatch = new CountDownLatch(1);
        ExecutorService fixedThreadPool = Executors.newFixedThreadPool(threadCount);
        for (int i = 0; i < threadCount; i++) {
            fixedThreadPool.execute(()->{
                try {
                    countDownLatch.await();
                    run.run();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }
        countDownLatch.countDown();
        fixedThreadPool.shutdown();
        while (!fixedThreadPool.isTerminated()){ }
        finish.finish();
    }
}

• 運(yùn)行接口

public interface Run {
    void run();
}

• 結(jié)束接口

public interface Finish {
    void finish();
}

• 測(cè)試

public class Test {
    static int m = 0;
    public static void main(String[] args) {
        AtomicInteger integer = new AtomicInteger(0);
        new ConcurrentTest().begin(10,()->{
            for (int i = 0; i < 10000; i++) {
//                integer.addAndGet(1);
                m++;
            }
        },()-> System.out.println(m));
    }
}