java多线程测试用例

public class ConcurrentTest {
    /**
     * 多线程测试用例
     * @param threadCount 开启线程数
     * @param run 线程执行方法
     * @param finish 线程全部执行结束后运行方法
     */
    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();
    }
}

• 运行接口

public interface Run {
    void run();
}

• 结束接口

public interface Finish {
    void finish();
}

• 测试

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