java.util.concurrent.CyclicBarrier 类的方法 getNumberWaiting() 返回随机输出

Question

我有一个使用 java.util.concurrent.CyclicBarrier 的示例，它使用 getNumberWaiting() 方法来获取等待方的数量。这种方法产生随机结果，有时它说 0 有时它说 1 这似乎不正确。

package sample;

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierTest {

    public static void main(String[] args) throws InterruptedException, BrokenBarrierException {
        // TODO Auto-generated method stub
        CyclicBarrier barrier = new CyclicBarrier(2);

        MyService service_1 = new MyService(barrier, "Service-1");
        MyService service_2 = new MyService(barrier, "Service-2");
        Thread t1 = new Thread(service_1);
        Thread t2 = new Thread(service_2);
        t1.start();
        t2.start();

    }
}

class MyService implements Runnable {

    private CyclicBarrier barrier;

    private String name;

    public MyService(CyclicBarrier barrier, String name) {
        super();
        this.barrier = barrier;
        this.name = name;
    }

    public void run() {
        System.out.println("Starting Service : " + name);
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("Service " + name + " : started");
        try {

            System.out.println("Parties waiting at barrier " + barrier.getNumberWaiting() + " parties");

            barrier.await();
            System.out.println("Breaking barrier for service : " + name);

        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (BrokenBarrierException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("Successfully done");
    }
}

实际结果:-
启动服务:Service-2
启动服务:Service-1
服务服务 1:已启动
服务服务 2:已启动
在屏障 0 方等候的方
在屏障 0 方等候的方
打破服务障碍:Service-2
成功完成
打破服务障碍:Service-1
成功完成

预期结果:-
启动服务:Service-2
启动服务:Service-1
服务服务 1:已启动
服务服务 2:已启动
在屏障 0 方等候的方
在障碍 1 派对等候的派对
打破服务障碍:Service-2
成功完成
打破服务障碍:Service-1
成功完成

Answer 1

由于两个线程是相同的(包括 sleep 值)，因此您可能会在意想不到的地方冒着两个线程交错的风险。在这种情况下，在 Parties waiting at barrier... 之后。

如果碰巧两个线程都已完成该输出但未启动它们的 await()，则数字将显示为 0。

如果您的目的只是验证 CyclicBarrier 的功能，则为每个线程设置不同的 sleep() 值将增加它们不以这种方式交错的机会>。