Java多线程：如何让线程在屏障暂停后按到达顺序恢复执行

问题分析 #

你当前方案的核心矛盾在于：无法原子性地完成“放行历史等待线程”和“允许新线程通行”的切换，导致要么新线程提前混入历史批次，要么部分新线程滞留在屏障中。要满足“历史等待线程优先执行、线程流顺序不变”的需求，必须把历史线程批次和新线程批次彻底隔离，确保历史批次执行完毕后才放行新线程。

改进实现方案 #

我们可以通过公平信号量（保证线程到达顺序）+ 倒计时门闩（等待历史批次全部完成）+ 原子状态标记的组合来实现需求：

核心变量定义

// 标记屏障是否处于激活拦截状态
private final AtomicBoolean barrierActive = new AtomicBoolean(false);
// 公平信号量：保证线程按到达顺序获取许可
private volatile Semaphore barrierSemaphore = new Semaphore(Integer.MAX_VALUE, true);
// 记录当前屏障下等待的线程数
private final AtomicInteger waitingThreadCount = new AtomicInteger(0);
// 用于等待历史批次所有线程通过屏障的门闩
private volatile CountDownLatch releaseLatch;

线程侧的屏障逻辑

每个线程进入屏障点时执行以下代码：

// 若屏障处于激活状态，则进入等待
if (barrierActive.get()) {
    waitingThreadCount.incrementAndGet();
    try {
        barrierSemaphore.acquire(); // 阻塞，直到被放行
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        return;
    }
    // 线程通过屏障后，通知门闩当前批次已完成一个线程
    if (releaseLatch != null) {
        releaseLatch.countDown();
    }
}
// 后续业务逻辑...

控制侧的屏障激活与放行

1. 激活屏障（开始拦截线程）

// 原子性切换屏障状态，避免并发冲突
if (barrierActive.compareAndSet(false, true)) {
    // 替换为permits=0的公平信号量，新线程进入后会阻塞
    barrierSemaphore = new Semaphore(0, true);
    waitingThreadCount.set(0);
    releaseLatch = null;
}

2. 放行历史批次线程并隔离新线程

if (barrierActive.get()) {
    int count = waitingThreadCount.getAndSet(0);
    if (count > 0) {
        // 创建门闩，等待当前批次所有线程通过屏障
        releaseLatch = new CountDownLatch(count);
        // 释放对应数量的许可，历史线程按到达顺序依次被唤醒
        barrierSemaphore.release(count);
        try {
            // 等待当前批次所有线程都通过屏障
            releaseLatch.await();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
    // 关闭屏障，允许新线程直接通过
    barrierActive.set(false);
    barrierSemaphore = new Semaphore(Integer.MAX_VALUE, true);
    releaseLatch = null;
}

方案优势 #

1. 顺序保证：使用公平Semaphore，线程按到达屏障的顺序获取许可，严格保证执行顺序。
2. 批次隔离：通过CountDownLatch等待历史批次所有线程完成后才关闭屏障，彻底避免新线程与历史线程混合。
3. 原子性控制：用AtomicBoolean保证屏障状态切换的原子性，避免并发场景下的状态不一致。

内容的提问来源于stack exchange，提问作者thefool