java多线程如何做单元测试

在 Java 中对多线程代码做单元测试是一个常见但容易踩坑的问题。下面从思路、常见工具、示例、注意事项几个层面系统讲一下。

一、核心思路

多线程单元测试的目标不是“测线程本身”，而是：

验证并发逻辑的正确性、可见性、原子性、同步是否正确

常见测试点：

• 共享变量是否线程安全
• synchronized / Lock 是否正确
• 线程间协作（wait/notify、CountDownLatch）
• 并发结果是否符合预期
• 是否出现死锁、竞态条件

二、最常用做法（推荐）

1️⃣ 使用 CountDownLatch 控制线程执行

这是最通用、最稳定的方式。

示例：测试多线程累加

public class Counter {
    private int count = 0;

    public void increment() {
        count++;
    }

    public int getCount() {
        return count;
    }
}

❌ 非线程安全，测试应能发现问题：

@Test
public void testCounter() throws InterruptedException {
    Counter counter = new Counter();
    int threadCount = 10;
    int perThread = 1000;

    CountDownLatch start = new CountDownLatch(1);
    CountDownLatch end = new CountDownLatch(threadCount);

    for (int i = 0; i < threadCount; i++) {
        new Thread(() -> {
            try {
                start.await();
                for (int j = 0; j < perThread; j++) {
                    counter.increment();
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            } finally {
                end.countDown();
            }
        }).start();
    }

    start.countDown();
    end.await();

    System.out.println(counter.getCount());
}

✅ 用于：

• 验证是否线程安全
• 复现并发问题

2️⃣ 使用 ExecutorService + Future

适合测试线程池逻辑：

ExecutorService pool = Executors.newFixedThreadPool(4);

List<Future<Integer>> futures = new ArrayList<>();
for (int i = 0; i < 4; i++) {
    futures.add(pool.submit(() -> 1));
}

int sum = 0;
for (Future<Integer> f : futures) {
    sum += f.get();
}
pool.shutdown();

三、专业并发测试工具（强烈推荐）

3️⃣ jcstress（JVM 并发压力测试）

官方并发测试工具，用于：

• 验证可见性
• 验证指令重排
• 验证原子性

@JCStressTest
@Outcome(id = "1", expect = Expect.ACCEPTABLE)
@State
public class VolatileTest {
    int x;
    volatile int y;

    @Actor
    public void actor1() {
        x = 1;
        y = 1;
    }

    @Actor
    public void actor2(II_Result r) {
        r.r1 = y;
        r.r2 = x;
    }
}

✅ 用于底层并发模型验证

4️⃣ TestableMock / Mockito + 线程

Mock 不改变并发本质，只用于：

• mock 外部依赖
• 验证方法是否被调用

when(service.getData()).thenReturn("mock");

5️⃣ ConcurrentUnit（轻量级）

@Test
public void testConcurrency() {
    ConcurrentTestCase tc = new ConcurrentTestCase();
    tc.runThreads(10, () -> {
        // 并发逻辑
    });
}

四、避免常见坑

❌ 不要在单线程里“假装多线程”

thread.run(); // 错误

✅ 必须用 start()

❌ 不要依赖 Thread.sleep() 断言

• 不稳定
• CI 上容易失败

✅ 用 CountDownLatch / CyclicBarrier

❌ 不要迷信“跑几次没出错就是对的”

并发 bug 是概率性的

五、推荐的测试策略组合

六、总结一句话

多线程单元测试的本质：用同步工具控制线程执行顺序，验证并发结果是否稳定正确。

如果你有：

• 具体代码（线程池 / Lock / volatile）
• 或想测“死锁 / 可见性 / 原子性”

可以直接贴代码，我可以帮你写可直接跑的测试。