使用 CyclicBarrier 在 barrier.await() 之后线程没有继续

Question

请帮助我编写代码。我正在使用 比赛起点和终点线各有 2 分。所有的马都从大门口出发，向大门口前进。比赛只有在所有马匹都到达大门后才开始。最先完成的人赢得比赛。

Answer 1

您的错误是您在此处提供的号码

gate= new CyclicBarrier(numHorses);

什么是 numHorses ？

这是所有马匹的数量，但在这里：

list.removeIf(...);

您要移除 18 岁以下的马匹，假设我们总共有 5 匹马，numHorses==5 是真的，其中两匹未满 18 岁，所以我们只剩下 3 匹。

您正在创建三个线程，但屏障设置为 5，屏障将永远不会通过，因为当只有三个线程时它正在等待 5 个线程。

解决方案是让addHorsesToList 添加没有障碍的马（所以你也需要一个没有障碍的Horse 构造函数），然后将gate = new CyclicBarrier 移动到list.removeIf 之后并将numHorses 更改为list.size()。

之后，您将障碍分配给list 中每个马对象的gate 字段。

这样做：

int canJoin=0;
    while(canJoin<2){
        list= new ArrayList<Horse>();
        numHorses=checkNumHorses();
        addHorsesToList();
        printHorses();
        canJoin=countJoinAge();
        }   

   list.removeIf(p -> p.Age().equals(18)); 
   int numHealthyHorses=list.size();
   gate=new CyclicBarrier(numHealthyHorses);  
   System.out.println("Horses who can join");

   Thread[] threads = new Thread[numHealthyHorses];
   for(Horse horse: list){     //create thread for each Horse
       horse.setGateBarrier(gate); //setter method, needs to be added to Horse class
       threads[numThread]= new Thread(horse);           
       }

   for(int i=0;i<numHealthyHorses;i++){     //start the thread for each horse
       threads[i].start();
       }}