我有一个使用 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
成功完成
最佳答案
由于两个线程是相同的(包括 sleep 值),因此您可能会在意想不到的地方冒着两个线程交错的风险。在这种情况下,在 Parties waiting at barrier...
之后。
如果碰巧两个线程都已完成该输出但未启动它们的 await()
,则数字将显示为 0。
如果您的目的只是验证 CyclicBarrier
的功能,则为每个线程设置不同的 sleep()
值将增加它们不以这种方式交错的机会>。
关于java.util.concurrent.CyclicBarrier 类的方法 getNumberWaiting() 返回随机输出,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54183165/