等待具有相同服务的其他线程到达某个点

Question

我用Java编写了一个多玩家网络游戏，玩家连接到服务器，并获得可以玩的“卡片”，每个玩家都有一个在自己的线程中生成的服务，可以处理所有事情。我想做的是找到一种方法，让服务器“暂停”，直到所有玩家都连接好并到达服务中的同一点，这样游戏就可以开始了。

服务器产生如下线程:

for (int i = 1; i <= numPlayers; i++){
    ArrayList<Card> playersCards = getPlayersCards(i-1);    
    Socket s = server.accept();
    System.out.println("Player "+ i +" connected.");
    Service service = new Service(s, playersCards);
    Thread t = new Thread(service);
    t.start();
}

然后我的服务：

public class Service implements Runnable {

    private Socket s;
    private Scanner in;
    private PrintWriter out;
    private ArrayList<Card> cards;


    public Service(Socket aSocket, ArrayList<Card> cards) {
        s = aSocket;
        this.cards = cards;
    }

    public void run() {
        try {
            in = new Scanner(s.getInputStream());
            out = new PrintWriter(s.getOutputStream());
            out.println("Welcome to the Simple Stock Market Game.");
            out.flush();
            sendCards();
            //AT THIS POINT THE SERVICE WOULD NEED TO wait for all players to connect
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            out.println("Thanks for playing the Simple Stock Market Game.");
            out.flush();
        }
        try {
            s.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
        System.out.println("Player disconnected."); 
    }

    private void sendCards() {
        Gson gson = new Gson();
        String cardsJSON = gson.toJson(cards);
        out.println(cardsJSON);
        out.flush();    
    }

}

现在我假设我可以通过服务，将有多少玩家，并等待那么多线程到达该点？不太确定，希望你们能帮忙！

Answer 1

如果您反复调用它，Phaser将是最好的解决方案，因为它以简单且可重复使用的方式结合了CountDownLatch和CyclicBarrier。对于一次性使用，CyclicBarrier就足够了（与Phaser相比性能略有提高）。

此外，请记住，如果您使用这样的同步工具，则会在出现错误时注销（在最终代码中），否则所有剩余方都将被无限期地卡住。

Answer 2

您可以使用java.util.concurrent.CountDownLatch，这正是您所需要的。

在创建服务的循环之前，使用预期的线程（玩家）数量对其进行初始化：

CountDownLatch playersLatch = new CountDownLatch(numPlayers);

然后在服务中：

playersLatch.countDown();
try {
    playersLatch.await();
} catch (InterruptedException ex) {
    //handle interruption
}

另外，您可能想看看java.util.concurrent.CyclicBarrier，它类似，但允许在等待线程释放后重用。