Java CyclicBarrier

Question

我有多个线程发送相同的数据包，并希望所有线程在继续发送下一个数据包之前完成。

我用下面的代码测试了CyclicBarrier：Test Code (was too long/messy to embed)这像预期的那样工作，输出0-4的组合，然后在一个循环中完成

对于数据包发送者，除了For循环之外，代码是等效的：

for(RSocket sendSocket : sendSocketList){
    new Thread(new Send(sendSocket , toServer)).start();
}
barrier.await();

发送的是：

private class Send implements Runnable{
    private RSocket sendSocket;
    private MPacket packet;
    public Send(RSocket sendSocket, MPacket packet){
        this.sendSocket = sendSocket;
        this.packet = packet;
    }
    public void run(){
        sendSocket.send(packet);
        try {
            barrier.await();
        } catch (InterruptedException | BrokenBarrierException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

RSocket.send(packet)；的功能与常规套接字的writeObject()函数相同，不同之处在于它会一直阻塞，直到完成(当它收到确认消息时)。假设网络方面是正确的，那么我是否正确地使用了CyclicBarrier？

附注:我应该指出，如果我使用for循环而没有启动新的线程，它会按预期工作，即：

for(RSocket sendSocket : sendSocketList){
    sendSocket.send(toServer);
}

Answer 1

是的，在本例中CyclicBarrier的用法是正确的。

只需注意一点：

根据代码，屏障必须初始化为sendSocketList.size()+1，因为还有调用await()：

• 的主线程