Java 循环屏障答案

【问题标题】：Java CyclicBarrierJava 循环屏障
【发布时间】：2016-06-10 12:59:03
【问题描述】：

我有多个线程发送同一个数据包，并希望所有线程都完成后再继续发送下一个数据包。

我使用以下代码测试了 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(数据包);功能与常规套接字的 writeObject() 函数相同，除了它会阻塞直到完成（当它接收到 ACK 时）。假设网络方面是正确的，我是否正确使用了 CyclicBarrier？

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

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

【问题讨论】：

如果代码太长/太乱而无法发布，则将其缩减为一个完整的可编译、可运行的示例来演示问题。
@JimGarrison 对不起，我不能发布完整的代码，因为它涉及许多其他类并且也是一个项目。我链接的示例本质上是该特定类试图做的并且是可编译的。
您实际上并未提出问题或陈述问题。您看到的问题是什么？有问题吗？如果不是，那么这是题外话，属于Code Review。

标签： java sockets concurrency barrier

【解决方案1】：

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

注意一点：

根据代码，屏障必须初始化为sendSocketList.size()+1，因为还有主线程调用await()：barrier = new CyclicBarrier(sendSocketList.size()+1);

【讨论】：